| .. ################################################################################ |
| Licensed to the Apache Software Foundation (ASF) under one |
| or more contributor license agreements. See the NOTICE file |
| distributed with this work for additional information |
| regarding copyright ownership. The ASF licenses this file |
| to you under the Apache License, Version 2.0 (the |
| "License"); you may not use this file except in compliance |
| with the License. You may obtain a copy of the License at |
| |
| http://www.apache.org/licenses/LICENSE-2.0 |
| |
| Unless required by applicable law or agreed to in writing, software |
| distributed under the License is distributed on an "AS IS" BASIS, |
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| See the License for the specific language governing permissions and |
| limitations under the License. |
| ################################################################################ |
| |
| |
| ======= |
| Formats |
| ======= |
| |
| Avro |
| ---- |
| |
| .. currentmodule:: pyflink.datastream.formats.avro |
| |
| .. autosummary:: |
| :toctree: api/ |
| |
| AvroSchema |
| GenericRecordAvroTypeInfo |
| AvroInputFormat |
| AvroBulkWriters |
| AvroRowDeserializationSchema |
| AvroRowSerializationSchema |
| |
| |
| CSV |
| --- |
| |
| .. currentmodule:: pyflink.datastream.formats.csv |
| |
| .. autosummary:: |
| :toctree: api/ |
| |
| CsvSchema |
| CsvSchemaBuilder |
| CsvReaderFormat |
| CsvBulkWriters |
| CsvRowDeserializationSchema |
| CsvRowSerializationSchema |
| |
| |
| Json |
| ---- |
| |
| .. currentmodule:: pyflink.datastream.formats.json |
| |
| .. autosummary:: |
| :toctree: api/ |
| |
| JsonRowDeserializationSchema |
| JsonRowSerializationSchema |
| |
| |
| Orc |
| --- |
| |
| .. currentmodule:: pyflink.datastream.formats.orc |
| |
| .. autosummary:: |
| :toctree: api/ |
| |
| OrcBulkWriters |
| |
| |
| Parquet |
| ------- |
| |
| .. currentmodule:: pyflink.datastream.formats.parquet |
| |
| .. autosummary:: |
| :toctree: api/ |
| |
| AvroParquetReaders |
| AvroParquetWriters |
| ParquetColumnarRowInputFormat |
| ParquetBulkWriters |
