geojson

Documentation

Index

• func FromParquet(reader parquet.ReaderAtSeeker, writer io.Writer) error
• func GetDefaultMetadata() *geoparquet.Metadata
• func ToParquet(input io.Reader, output io.Writer, convertOptions *ConvertOptions) error
• type ConvertOptions
• type FeatureReader
  • func NewFeatureReader(input io.Reader) *FeatureReader
  • func (r *FeatureReader) Read() (*geo.Feature, error)
• type RecordWriter
  • func NewRecordWriter(writer io.Writer, geoMetadata *geoparquet.Metadata) (*RecordWriter, error)
  • func (w *RecordWriter) Close() error
  • func (w *RecordWriter) Write(record arrow.Record) error

Functions

func FromParquet

func FromParquet(reader parquet.ReaderAtSeeker, writer io.Writer) error

func GetDefaultMetadata

func GetDefaultMetadata() *geoparquet.Metadata

func ToParquet

func ToParquet(input io.Reader, output io.Writer, convertOptions *ConvertOptions) error

Types

type ConvertOptions

type ConvertOptions struct {
	MinFeatures    int
	MaxFeatures    int
	Compression    string
	RowGroupLength int
	Metadata       string
}

type FeatureReader

type FeatureReader struct {
	// contains filtered or unexported fields
}

func NewFeatureReader

func NewFeatureReader(input io.Reader) *FeatureReader

func (*FeatureReader) Read

func (r *FeatureReader) Read() (*geo.Feature, error)

type RecordWriter

type RecordWriter struct {
	// contains filtered or unexported fields
}

func NewRecordWriter

func NewRecordWriter(writer io.Writer, geoMetadata *geoparquet.Metadata) (*RecordWriter, error)

func (*RecordWriter) Close

func (w *RecordWriter) Close() error

func (*RecordWriter) Write

func (w *RecordWriter) Write(record arrow.Record) error