Path	Lines of Code
flink-connector-odps/src/main/java/org/apache/flink/odps/FlinkOdpsException.java	12
flink-connector-odps/src/main/java/org/apache/flink/odps/catalog/OdpsCatalog.java	650
flink-connector-odps/src/main/java/org/apache/flink/odps/catalog/factories/OdpsCatalogFactory.java	47
flink-connector-odps/src/main/java/org/apache/flink/odps/catalog/factories/OdpsCatalogFactoryOptions.java	19
flink-connector-odps/src/main/java/org/apache/flink/odps/input/OdpsInputFormat.java	433
flink-connector-odps/src/main/java/org/apache/flink/odps/input/OdpsInputSplit.java	16
flink-connector-odps/src/main/java/org/apache/flink/odps/input/OdpsLookupFunction.java	128
flink-connector-odps/src/main/java/org/apache/flink/odps/input/OdpsLookupOptions.java	45
flink-connector-odps/src/main/java/org/apache/flink/odps/input/reader/CupidBatchIterator.java	87
flink-connector-odps/src/main/java/org/apache/flink/odps/input/reader/NextIterator.java	90
flink-connector-odps/src/main/java/org/apache/flink/odps/input/reader/RecordIterator.java	94
flink-connector-odps/src/main/java/org/apache/flink/odps/output/OdpsOutputFormat.java	230
flink-connector-odps/src/main/java/org/apache/flink/odps/output/OdpsSinkFunction.java	265
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/DateTimePartitionAssigner.java	63
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/DefaultSinkPolicy.java	91
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/PartitionAssigner.java	13
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/PartitionComputer.java	70
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/SinkPolicy.java	10
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/TablePartitionAssigner.java	16
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsStreamWrite.java	7
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsTableWrite.java	203
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsWrite.java	11
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsWriteFactory.java	69
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsWriteOptions.java	147
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsWriterInfo.java	56
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/WriterContext.java	39
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/file/BlockWriter.java	11
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/file/ColumnarBlockWriter.java	51
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/file/RowBlockWriter.java	122
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/file/StaticOdpsPartitionWrite.java	122
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/stream/DynamicOdpsPartitionStreamWrite.java	129
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/stream/GroupedOdpsPartitionStreamWrite.java	63
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/stream/RowStreamWriter.java	69
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/stream/StaticOdpsPartitionStreamWrite.java	98
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/stream/StreamWriter.java	8
flink-connector-odps/src/main/java/org/apache/flink/odps/schema/OdpsColumn.java	54
flink-connector-odps/src/main/java/org/apache/flink/odps/schema/OdpsTableSchema.java	61
flink-connector-odps/src/main/java/org/apache/flink/odps/table/OdpsDynamicTableSink.java	263
flink-connector-odps/src/main/java/org/apache/flink/odps/table/OdpsDynamicTableSource.java	201
flink-connector-odps/src/main/java/org/apache/flink/odps/table/OdpsOptions.java	117
flink-connector-odps/src/main/java/org/apache/flink/odps/table/OdpsTablePath.java	73
flink-connector-odps/src/main/java/org/apache/flink/odps/table/factories/OdpsDynamicTableFactory.java	181
flink-connector-odps/src/main/java/org/apache/flink/odps/util/Constants.java	39
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsConf.java	133
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsMetaDataProvider.java	162
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsTableUtil.java	40
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsTypeConverter.java	790
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsTypeUtil.java	214
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsUtils.java	248
flink-connector-odps/src/main/java/org/apache/flink/odps/util/PartitionPath.java	52
flink-connector-odps/src/main/java/org/apache/flink/odps/vectorized/ColDataRowImpl.java	136
flink-connector-odps/src/main/java/org/apache/flink/odps/vectorized/ColumnarReadBatch.java	40
flink-connector-odps/src/main/java/org/apache/flink/odps/vectorized/MutableColumnarRow.java	97