Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DateHourKey ¶
type ParquetS3FileWriter ¶
type ParquetS3FileWriter struct {
// contains filtered or unexported fields
}
func NewParquetS3FileWriter ¶
func NewParquetS3FileWriter(api s3v2.S3API, bucket string, prefix string, key DateHourKey, sampleObj interface{}) (*ParquetS3FileWriter, error)
func (*ParquetS3FileWriter) Close ¶
func (w *ParquetS3FileWriter) Close() error
func (*ParquetS3FileWriter) RotateFile ¶
func (w *ParquetS3FileWriter) RotateFile() error
func (*ParquetS3FileWriter) Write ¶
func (w *ParquetS3FileWriter) Write(obj interface{}) error
type Rotatable ¶
type Rotatable interface { GetDateHourKey() DateHourKey UpdateFields() error }
type RotatingWriter ¶
type RotatingWriter struct {
// contains filtered or unexported fields
}
func NewRotatingWriter ¶
func (*RotatingWriter) CleanFiles ¶
func (r *RotatingWriter) CleanFiles() error
func (*RotatingWriter) Close ¶
func (r *RotatingWriter) Close() error
func (*RotatingWriter) Write ¶
func (r *RotatingWriter) Write(obj Rotatable) error
Click to show internal directories.
Click to hide internal directories.