partitions

Documentation

Index

• Variables
• type TDataPartition
  • func NewTDataPartition() *TDataPartition
  • func (p *TDataPartition) Equals(other *TDataPartition) bool
  • func (p *TDataPartition) GetPartitionExprs() []*exprs.TExpr
  • func (p *TDataPartition) GetType() TPartitionType
  • func (p *TDataPartition) IsSetPartitionExprs() bool
  • func (p *TDataPartition) Read(ctx context.Context, iprot thrift.TProtocol) error
  • func (p *TDataPartition) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
  • func (p *TDataPartition) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
  • func (p *TDataPartition) String() string
  • func (p *TDataPartition) Write(ctx context.Context, oprot thrift.TProtocol) error
• type TPartitionType
  • func TPartitionTypeFromString(s string) (TPartitionType, error)
  • func TPartitionTypePtr(v TPartitionType) *TPartitionType
  • func (p TPartitionType) MarshalText() ([]byte, error)
  • func (p *TPartitionType) Scan(value interface{}) error
  • func (p TPartitionType) String() string
  • func (p *TPartitionType) UnmarshalText(text []byte) error
  • func (p *TPartitionType) Value() (driver.Value, error)

Variables

var GoUnusedProtection__ int

var TDataPartition_PartitionExprs_DEFAULT []*exprs.TExpr

Types

type TDataPartition

type TDataPartition struct {
	Type           TPartitionType `thrift:"type,1,required" db:"type" json:"type"`
	PartitionExprs []*exprs.TExpr `thrift:"partition_exprs,2" db:"partition_exprs" json:"partition_exprs,omitempty"`
}

Attributes:

• Type
• PartitionExprs

func NewTDataPartition

func NewTDataPartition() *TDataPartition

func (*TDataPartition) Equals

func (p *TDataPartition) Equals(other *TDataPartition) bool

func (*TDataPartition) GetPartitionExprs

func (p *TDataPartition) GetPartitionExprs() []*exprs.TExpr

func (*TDataPartition) GetType

func (p *TDataPartition) GetType() TPartitionType

func (*TDataPartition) IsSetPartitionExprs

func (p *TDataPartition) IsSetPartitionExprs() bool

func (*TDataPartition) Read

func (p *TDataPartition) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataPartition) ReadField1

func (p *TDataPartition) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataPartition) ReadField2

func (p *TDataPartition) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataPartition) String

func (p *TDataPartition) String() string

func (*TDataPartition) Write

func (p *TDataPartition) Write(ctx context.Context, oprot thrift.TProtocol) error

type TPartitionType

type TPartitionType int64

const (
	TPartitionType_UNPARTITIONED     TPartitionType = 0
	TPartitionType_RANDOM            TPartitionType = 1
	TPartitionType_HASH_PARTITIONED  TPartitionType = 2
	TPartitionType_RANGE_PARTITIONED TPartitionType = 3
	TPartitionType_KUDU              TPartitionType = 4
)

func TPartitionTypeFromString

func TPartitionTypeFromString(s string) (TPartitionType, error)

func TPartitionTypePtr

func TPartitionTypePtr(v TPartitionType) *TPartitionType

func (TPartitionType) MarshalText

func (p TPartitionType) MarshalText() ([]byte, error)

func (*TPartitionType) Scan

func (p *TPartitionType) Scan(value interface{}) error

func (TPartitionType) String

func (p TPartitionType) String() string

func (*TPartitionType) UnmarshalText

func (p *TPartitionType) UnmarshalText(text []byte) error

func (*TPartitionType) Value

func (p *TPartitionType) Value() (driver.Value, error)