Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
func CreateS3Client ¶
func CreateS3Client(config config.S3ClientConfig) *Client
type ParquetWriter ¶
type ParquetWriter struct {
// contains filtered or unexported fields
}
func CreateS3ParquetWriter ¶
func (*ParquetWriter) Close ¶
func (writer *ParquetWriter) Close() error
func (*ParquetWriter) WriteRows ¶
func (writer *ParquetWriter) WriteRows(rows []interface{}) error
type ParquetWriterFactory ¶
type ParquetWriterFactory struct {
// contains filtered or unexported fields
}
func CreateS3ParquetWriterFactory ¶
func CreateS3ParquetWriterFactory(logger *zap.Logger, s3Client *Client, schema *parquet.Schema, snapshotConfig config.SnapshotConfig, part int) *ParquetWriterFactory
func (*ParquetWriterFactory) Close ¶
func (factory *ParquetWriterFactory) Close() error
func (*ParquetWriterFactory) WriteRows ¶
func (factory *ParquetWriterFactory) WriteRows(rows []interface{}) error
Source Files
Click to show internal directories.
Click to hide internal directories.