DeserializationSchema < Row > function ( ) { return deserializationSchema ; }
returns the deserialization schema . concode_field_sep TypeInformation<?>[] fieldTypes concode_elem_sep String[] fieldNames concode_elem_sep String topic concode_elem_sep DeserializationSchema<Row> deserializationSchema concode_elem_sep Properties properties concode_field_sep String[] getFieldsNames concode_elem_sep int getNumberOfFields concode_elem_sep FlinkKafkaConsumerBase<Row> getKafkaConsumer concode_elem_sep TypeInformation<Row> getReturnType concode_elem_sep TypeInformation<?>[] toTypeInfo concode_elem_sep DataStream<Row> getDataStream concode_elem_sep TypeInformation<?>[] getFieldTypes