Versions in this module Expand all Collapse all v0 v0.0.4 Oct 14, 2022 Changes in this version + func NewS3FileReader(ctx context.Context, bucket string, key string, cfgs ...*aws.Config) (source.ParquetFile, error) + func NewS3FileReaderVersioned(ctx context.Context, bucket string, key string, version *string, ...) (source.ParquetFile, error) + func NewS3FileReaderVersionedWithClient(ctx context.Context, s3Client s3iface.S3API, bucket string, key string, ...) (source.ParquetFile, error) + func NewS3FileReaderWithClient(ctx context.Context, s3Client s3iface.S3API, bucket string, key string) (source.ParquetFile, error) + func NewS3FileReaderWithParams(ctx context.Context, params S3FileReaderParams) (source.ParquetFile, error) + func NewS3FileWriter(ctx context.Context, bucket string, key string, acl string, ...) (source.ParquetFile, error) + func NewS3FileWriterWithClient(ctx context.Context, s3Client s3iface.S3API, bucket string, key string, ...) (source.ParquetFile, error) + func SetActiveSession(sess *session.Session) + type S3File struct + ACL string + BucketName string + Key string + VersionId *string + func (s *S3File) Close() error + func (s *S3File) Create(key string) (source.ParquetFile, error) + func (s *S3File) Open(name string) (source.ParquetFile, error) + func (s *S3File) Read(p []byte) (n int, err error) + func (s *S3File) Seek(offset int64, whence int) (int64, error) + func (s *S3File) Write(p []byte) (n int, err error) + type S3FileReaderParams struct + Bucket string + Configs []*aws.Config + Key string + MinRequestSize int + S3Client s3iface.S3API + Version *string
Go to main page