THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
public static final String FORMAT_THRIFT_CLASS = "format.thrift-struct";
}
KafkaDynamicSource
We propose kafka tablesource implements SupportsProjectionPushDown
...
SupportsProjectionPushDown {
In implementation, we only reconstruct DeserializationSchema that takes list of fields
@Override
...
// check valueDecodingFormat is ThriftDeserializationSchema
// if so reconstruct DeserializationSchema that does partial deserialize
}
protectedfinalDecodingFormat<DeserializationSchema<RowData>> valueDecodingFormat;
...