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 NewS3FileReaderWithClient(ctx context.Context, s3Client S3API, bucket string, key string) (source.ParquetFile, error) + func NewS3FileReaderWithClientVersioned(ctx context.Context, s3Client 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, ...) (source.ParquetFile, error) + func NewS3FileWriterWithClient(ctx context.Context, s3Client S3API, bucket string, key string, ...) (source.ParquetFile, error) + type S3API interface + AbortMultipartUpload func(context.Context, *s3.AbortMultipartUploadInput, ...func(*s3.Options)) (*s3.AbortMultipartUploadOutput, error) + CompleteMultipartUpload func(context.Context, *s3.CompleteMultipartUploadInput, ...func(*s3.Options)) (*s3.CompleteMultipartUploadOutput, error) + CreateMultipartUpload func(context.Context, *s3.CreateMultipartUploadInput, ...func(*s3.Options)) (*s3.CreateMultipartUploadOutput, error) + GetObject func(context.Context, *s3.GetObjectInput, ...func(*s3.Options)) (*s3.GetObjectOutput, error) + HeadObject func(ctx context.Context, params *s3.HeadObjectInput, optFns ...func(*s3.Options)) (*s3.HeadObjectOutput, error) + PutObject func(context.Context, *s3.PutObjectInput, ...func(*s3.Options)) (*s3.PutObjectOutput, error) + UploadPart func(context.Context, *s3.UploadPartInput, ...func(*s3.Options)) (*s3.UploadPartOutput, error) + type S3File struct + BucketName string + Key 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 + Key string + MinRequestSize int + S3Client S3API + Version *string
Go to main page