azblob

package

v0.0.0-...-d629458 Latest Latest Go to latest Published: Jan 22, 2024 License: Apache-2.0 Imports: 8 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/xitongsys/parquet-go-source

Links

Open Source Insights

Documentation ¶

Index ¶

func NewAzBlobFileReader(ctx context.Context, URL string, credential azcore.TokenCredential, ...) (source.ParquetFile, error)
func NewAzBlobFileReaderWithClient(ctx context.Context, URL string, client *blockblob.Client) (source.ParquetFile, error)
func NewAzBlobFileReaderWithSharedKey(ctx context.Context, URL string, credential *blob.SharedKeyCredential, ...) (source.ParquetFile, error)
func NewAzBlobFileWriter(ctx context.Context, URL string, credential azcore.TokenCredential, ...) (source.ParquetFile, error)
func NewAzBlobFileWriterWithClient(ctx context.Context, URL string, client *blockblob.Client) (source.ParquetFile, error)
func NewAzBlobFileWriterWithSharedKey(ctx context.Context, URL string, credential *blob.SharedKeyCredential, ...) (source.ParquetFile, error)
type AzBlockBlob

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewAzBlobFileReader ¶

func NewAzBlobFileReader(ctx context.Context, URL string, credential azcore.TokenCredential, clientOptions blockblob.ClientOptions) (source.ParquetFile, error)

NewAzBlobFileReader creates an Azure Blob FileReader, to be used with NewParquetReader

func NewAzBlobFileReaderWithClient ¶

func NewAzBlobFileReaderWithClient(ctx context.Context, URL string, client *blockblob.Client) (source.ParquetFile, error)

NewAzBlobFileReaderWithClient creates an Azure Blob FileReader, to be used with NewParquetReader

func NewAzBlobFileReaderWithSharedKey ¶

func NewAzBlobFileReaderWithSharedKey(ctx context.Context, URL string, credential *blob.SharedKeyCredential, clientOptions blockblob.ClientOptions) (source.ParquetFile, error)

NewAzBlobFileReaderWithSharedKey creates an Azure Blob FileReader, to be used with NewParquetReader

func NewAzBlobFileWriter ¶

func NewAzBlobFileWriter(ctx context.Context, URL string, credential azcore.TokenCredential, clientOptions blockblob.ClientOptions) (source.ParquetFile, error)

NewAzBlobFileWriter creates an Azure Blob FileWriter, to be used with NewParquetWriter

func NewAzBlobFileWriterWithClient ¶

func NewAzBlobFileWriterWithClient(ctx context.Context, URL string, client *blockblob.Client) (source.ParquetFile, error)

NewAzBlobFileWriterWithClient creates an Azure Blob FileWriter, to be used with NewParquetWriter

func NewAzBlobFileWriterWithSharedKey ¶

func NewAzBlobFileWriterWithSharedKey(ctx context.Context, URL string, credential *blob.SharedKeyCredential, clientOptions blockblob.ClientOptions) (source.ParquetFile, error)

NewAzBlobFileWriterWithSharedKey creates an Azure Blob FileWriter, to be used with NewParquetWriter

Types ¶

type AzBlockBlob ¶

type AzBlockBlob struct {
	URL *url.URL
	// contains filtered or unexported fields
}

AzBlockBlob is ParquetFile for azblob

func (*AzBlockBlob) Close ¶

func (s *AzBlockBlob) Close() error

Close signals write completion and cleans up any open streams. Will block until pending uploads are complete.

func (*AzBlockBlob) Create ¶

func (s *AzBlockBlob) Create(URL string) (source.ParquetFile, error)

Create a new blob url to perform writes

func (*AzBlockBlob) Open ¶

func (s *AzBlockBlob) Open(URL string) (source.ParquetFile, error)

Open creates a new block blob to perform reads

func (*AzBlockBlob) Read ¶

func (s *AzBlockBlob) Read(p []byte) (n int, err error)

Read up to len(p) bytes into p and return the number of bytes read

func (*AzBlockBlob) Seek ¶

func (s *AzBlockBlob) Seek(offset int64, whence int) (int64, error)

Seek tracks the offset for the next Read. Has no effect on Write.

func (*AzBlockBlob) Write ¶

func (s *AzBlockBlob) Write(p []byte) (n int, err error)

Write len(p) bytes from p

Source Files ¶

View all Source files

azblob.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL