Versions in this module Expand all Collapse all v11 v11.0.0 Jan 18, 2023 Changes in this version + var OutputFirstType = exec.NewComputedOutputType(func(_ *exec.KernelCtx, args []arrow.DataType) (arrow.DataType, error) { ... }) + var OutputLastType = exec.NewComputedOutputType(func(_ *exec.KernelCtx, args []arrow.DataType) (arrow.DataType, error) { ... }) + var OutputResolveTemporal = exec.NewComputedOutputType(resolveTemporalOutput) + var OutputTargetType = exec.NewComputedOutputType(ResolveOutputFromOptions) + func ArithmeticExec(ity, oty arrow.Type, op ArithmeticOp) exec.ArrayKernelExec + func ArithmeticExecSameType(ty arrow.Type, op ArithmeticOp) exec.ArrayKernelExec + func CanCastFromDict(id arrow.Type) bool + func CastBinaryToBinary(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastDecimal128ToInteger(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastDecimal256ToInteger(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastDecimalToDecimal(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastDecimalToFloating(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastFloat32ToDecimal(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastFloat64ToDecimal(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastFloatingToFloating(_ *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastFloatingToInteger(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastFromNull(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastFsbToBinary(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastFsbToFsb(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastIntToInt(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastIntegerToDecimal(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func CastIntegerToFloating(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func ChunkedPrimitiveTake(ctx *exec.KernelCtx, batch []*arrow.Chunked, out *exec.ExecResult) ([]*exec.ExecResult, error) + func ChunkedTakeSupported(dt arrow.DataType) bool + func CompareKernels(op CompareOperator) []exec.ScalarKernel + func DenseUnionImpl(ctx *exec.KernelCtx, batch *exec.ExecSpan, outputLength int64, ...) error + func DoStaticCast(in []InT, out []OutT) + func FSBImpl(ctx *exec.KernelCtx, batch *exec.ExecSpan, outputLength int64, ...) error + func FSLImpl(ctx *exec.KernelCtx, batch *exec.ExecSpan, outputLength int64, ...) error + func FilterBinary(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func FilterExec(impl selectionImplFn) exec.ArrayKernelExec + func FixedRoundDecimalExec(mode RoundMode) exec.ArrayKernelExec + func GetArithmeticBinaryKernels(op ArithmeticOp) []exec.ScalarKernel + func GetArithmeticFloatingPointKernels(op ArithmeticOp) []exec.ScalarKernel + func GetArithmeticFunctionTimeDuration(op ArithmeticOp) []exec.ScalarKernel + func GetArithmeticUnaryFixedIntOutKernels(otype arrow.DataType, op ArithmeticOp) []exec.ScalarKernel + func GetArithmeticUnaryFloatingPointKernels(op ArithmeticOp) []exec.ScalarKernel + func GetArithmeticUnaryKernels(op ArithmeticOp) []exec.ScalarKernel + func GetArithmeticUnarySignedKernels(op ArithmeticOp) []exec.ScalarKernel + func GetBitwiseBinaryKernels(op BitwiseOp) []exec.ScalarKernel + func GetBitwiseUnaryKernels() []exec.ScalarKernel + func GetBooleanCastKernels() []exec.ScalarKernel + func GetCastToDecimal128() []exec.ScalarKernel + func GetCastToDecimal256() []exec.ScalarKernel + func GetCastToFloating(outType arrow.DataType) []exec.ScalarKernel + func GetCastToInteger(outType arrow.DataType) []exec.ScalarKernel + func GetCommonCastKernels(outID arrow.Type, outType exec.OutputType) (out []exec.ScalarKernel) + func GetCompareKernel(ty exec.InputType, cmpType arrow.Type, op CompareOperator) exec.ScalarKernel + func GetDate32CastKernels() []exec.ScalarKernel + func GetDate64CastKernels() []exec.ScalarKernel + func GetDecimalBinaryKernels(op ArithmeticOp) []exec.ScalarKernel + func GetDecimalUnaryKernels(op ArithmeticOp) []exec.ScalarKernel + func GetDurationCastKernels() []exec.ScalarKernel + func GetFsbCastKernels() []exec.ScalarKernel + func GetIntervalCastKernels() []exec.ScalarKernel + func GetRoundUnaryKernels(init exec.KernelInitFn, knFn func(arrow.Type) exec.ArrayKernelExec) []exec.ScalarKernel + func GetShiftKernels(dir ShiftDir, checked bool) []exec.ScalarKernel + func GetSimpleRoundKernels(mode RoundMode) []exec.ScalarKernel + func GetTakeIndices(mem memory.Allocator, filter *exec.ArraySpan, nullSelect NullSelectionBehavior) (arrow.ArrayData, error) + func GetTime32CastKernels() []exec.ScalarKernel + func GetTime64CastKernels() []exec.ScalarKernel + func GetTimestampCastKernels() []exec.ScalarKernel + func GetToBinaryKernels(outType arrow.DataType) []exec.ScalarKernel + func GetZeroCastKernel(inID arrow.Type, inType exec.InputType, out exec.OutputType) exec.ScalarKernel + func InitRoundState(_ *exec.KernelCtx, args exec.KernelInitArgs) (exec.KernelState, error) + func InitRoundToMultipleState(_ *exec.KernelCtx, args exec.KernelInitArgs) (exec.KernelState, error) + func ListImpl(ctx *exec.KernelCtx, batch *exec.ExecSpan, outputLength int64, ...) error + func MaxDecimalDigitsForInt(id arrow.Type) (int32, error) + func MaxOf() T + func MinOf() T + func NullExecKernel(nargs int) exec.ScalarKernel + func NullFilter(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func NullTake(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func NullToNullExec(_ *exec.KernelCtx, _ *exec.ExecSpan, _ *exec.ExecResult) error + func OutputAllNull(_ *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func PrimitiveFilter(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func PrimitiveTake(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func ResolveOutputFromOptions(ctx *exec.KernelCtx, _ []arrow.DataType) (arrow.DataType, error) + func ScalarBinary(ops binaryOps[OutT, Arg0T, Arg1T]) exec.ArrayKernelExec + func ScalarBinaryBinaryArgsBoolOut(itrFn func(*exec.ArraySpan) exec.ArrayIter[[]byte], op binaryBinOp[bool]) exec.ArrayKernelExec + func ScalarBinaryBools(ops *binaryBoolOps) exec.ArrayKernelExec + func ScalarBinaryNotNull(op func(*exec.KernelCtx, Arg0T, Arg1T, *error) OutT) exec.ArrayKernelExec + func ScalarUnary(op func(*exec.KernelCtx, []Arg0T, []OutT) error) exec.ArrayKernelExec + func ScalarUnaryBoolArg(op func(*exec.KernelCtx, []byte, []OutT) error) exec.ArrayKernelExec + func ScalarUnaryBoolOutput(op func(*exec.KernelCtx, []Arg0T, []byte) error) exec.ArrayKernelExec + func ScalarUnaryNotNull(op func(*exec.KernelCtx, Arg0T, *error) OutT) exec.ArrayKernelExec + func ScalarUnaryNotNullBinaryArg(op func(*exec.KernelCtx, []byte, *error) OutT) exec.ArrayKernelExec + func ScalarUnaryNotNullBinaryArgBoolOut(defVal bool, op func(*exec.KernelCtx, []byte, *error) bool) exec.ArrayKernelExec + func ShiftTime(ctx *exec.KernelCtx, op arrow.TimestampConvertOp, factor int64, ...) error + func SimpleBinary(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func SimpleTemporalCast(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func SizeOf() uint + func StringToTimestamp(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func StructImpl(ctx *exec.KernelCtx, batch *exec.ExecSpan, outputLength int64, ...) error + func SubtractDate32(op ArithmeticOp) exec.ArrayKernelExec + func TakeExec(impl selectionImplFn) exec.ArrayKernelExec + func TimestampToDate32(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func TimestampToDate64(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func TimestampToTime32(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func TimestampToTime64(ctx *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + func UnaryRoundExec(ty arrow.Type) exec.ArrayKernelExec + func UnaryRoundToMultipleExec(ty arrow.Type) exec.ArrayKernelExec + func UnboxBinaryScalar(val scalar.BinaryScalar) []byte + func UnboxScalar(val scalar.PrimitiveScalar) T + func VarBinaryImpl(ctx *exec.KernelCtx, batch *exec.ExecSpan, outputLength int64, ...) error + func ZeroCopyCastExec(_ *exec.KernelCtx, batch *exec.ExecSpan, out *exec.ExecResult) error + type AndNotOpKernel struct + func (AndNotOpKernel) Call(ctx *exec.KernelCtx, left, right *exec.ArraySpan, out *exec.ExecResult) error + func (AndNotOpKernel) CallScalarLeft(ctx *exec.KernelCtx, left scalar.Scalar, right *exec.ArraySpan, ...) error + func (AndNotOpKernel) CallScalarRight(ctx *exec.KernelCtx, left *exec.ArraySpan, right scalar.Scalar, ...) error + type AndOpKernel struct + func (AndOpKernel) Call(ctx *exec.KernelCtx, left, right *exec.ArraySpan, out *exec.ExecResult) error + func (AndOpKernel) CallScalarLeft(ctx *exec.KernelCtx, left scalar.Scalar, right *exec.ArraySpan, ...) error + func (AndOpKernel) CallScalarRight(ctx *exec.KernelCtx, left *exec.ArraySpan, right scalar.Scalar, ...) error + type ArithmeticOp int8 + const OpAbsoluteValue + const OpAbsoluteValueChecked + const OpAcos + const OpAcosChecked + const OpAdd + const OpAddChecked + const OpAsin + const OpAsinChecked + const OpAtan + const OpAtan2 + const OpCos + const OpCosChecked + const OpDiv + const OpDivChecked + const OpLn + const OpLnChecked + const OpLog10 + const OpLog10Checked + const OpLog1p + const OpLog1pChecked + const OpLog2 + const OpLog2Checked + const OpLogb + const OpLogbChecked + const OpMul + const OpMulChecked + const OpNegate + const OpNegateChecked + const OpPower + const OpPowerChecked + const OpSign + const OpSin + const OpSinChecked + const OpSqrt + const OpSqrtChecked + const OpSub + const OpSubChecked + const OpTan + const OpTanChecked + type BitwiseOp int8 + const OpBitAnd + const OpBitOr + const OpBitXor + type CastOptions struct + AllowDecimalTruncate bool + AllowFloatTruncate bool + AllowIntOverflow bool + AllowInvalidUtf8 bool + AllowTimeOverflow bool + AllowTimeTruncate bool + ToType arrow.DataType + func (CastOptions) TypeName() string + type CastState = CastOptions + type CompareData struct + func (c *CompareData) Funcs() *CompareData + type CompareFuncData interface + Funcs func() *CompareData + type CompareOperator int8 + const CmpEQ + const CmpGE + const CmpGT + const CmpLE + const CmpLT + const CmpNE + func (i CompareOperator) String() string + type FilterOptions struct + NullSelection NullSelectionBehavior + func (FilterOptions) TypeName() string + type FilterState = FilterOptions + type KleeneAndNotOpKernel struct + func (KleeneAndNotOpKernel) Call(ctx *exec.KernelCtx, left, right *exec.ArraySpan, out *exec.ExecResult) error + func (KleeneAndNotOpKernel) CallScalarLeft(ctx *exec.KernelCtx, left scalar.Scalar, right *exec.ArraySpan, ...) error + func (KleeneAndNotOpKernel) CallScalarRight(ctx *exec.KernelCtx, left *exec.ArraySpan, right scalar.Scalar, ...) error + type KleeneAndOpKernel struct + func (KleeneAndOpKernel) Call(ctx *exec.KernelCtx, left, right *exec.ArraySpan, out *exec.ExecResult) error + func (KleeneAndOpKernel) CallScalarLeft(ctx *exec.KernelCtx, left scalar.Scalar, right *exec.ArraySpan, ...) error + func (KleeneAndOpKernel) CallScalarRight(ctx *exec.KernelCtx, left *exec.ArraySpan, right scalar.Scalar, ...) error + type KleeneOrOpKernel struct + func (KleeneOrOpKernel) Call(ctx *exec.KernelCtx, left, right *exec.ArraySpan, out *exec.ExecResult) error + func (KleeneOrOpKernel) CallScalarLeft(ctx *exec.KernelCtx, left scalar.Scalar, right *exec.ArraySpan, ...) error + func (KleeneOrOpKernel) CallScalarRight(ctx *exec.KernelCtx, left *exec.ArraySpan, right scalar.Scalar, ...) error + type NullSelectionBehavior int8 + const DropNulls + const EmitNulls + type OrOpKernel struct + func (OrOpKernel) Call(ctx *exec.KernelCtx, left, right *exec.ArraySpan, out *exec.ExecResult) error + func (OrOpKernel) CallScalarLeft(ctx *exec.KernelCtx, left scalar.Scalar, right *exec.ArraySpan, ...) error + func (OrOpKernel) CallScalarRight(ctx *exec.KernelCtx, left *exec.ArraySpan, right scalar.Scalar, ...) error + type RoundMode int8 + const AwayFromZero + const HalfAwayFromZero + const HalfDown + const HalfToEven + const HalfToOdd + const HalfTowardsZero + const HalfUp + const RoundDown + const RoundUp + const TowardsZero + func (i RoundMode) String() string + type RoundOptions struct + Mode RoundMode + NDigits int64 + func (RoundOptions) TypeName() string + type RoundState struct + Pow10 float64 + type RoundToMultipleOptions struct + Mode RoundMode + Multiple scalar.Scalar + func (RoundToMultipleOptions) TypeName() string + type RoundToMultipleState = RoundToMultipleOptions + type SelectionKernelData struct + Chunked exec.ChunkedExec + Exec exec.ArrayKernelExec + In exec.InputType + func GetVectorSelectionKernels() (filterkernels, takeKernels []SelectionKernelData) + type ShiftDir int8 + const ShiftLeft + const ShiftRight + type SimpleBinaryKernel interface + CallScalarRight func(*exec.KernelCtx, *exec.ArraySpan, scalar.Scalar, *exec.ExecResult) error + type TakeOptions struct + BoundsCheck bool + func (TakeOptions) TypeName() string + type TakeState = TakeOptions + type XorOpKernel struct + func (XorOpKernel) Call(ctx *exec.KernelCtx, left, right *exec.ArraySpan, out *exec.ExecResult) error + func (XorOpKernel) CallScalarLeft(ctx *exec.KernelCtx, left scalar.Scalar, right *exec.ArraySpan, ...) error + func (XorOpKernel) CallScalarRight(ctx *exec.KernelCtx, left *exec.ArraySpan, right scalar.Scalar, ...) error Other modules containing this package github.com/apache/arrow/go/v12 github.com/apache/arrow/go/v13 github.com/apache/arrow/go/v14 github.com/apache/arrow/go/v15 github.com/apache/arrow/go/v16
Go to main page