ColumnVector-spark技术分享

ColumnVector

ColumnVector is the contract for…FIXME



package org.apache.spark.sql.vectorized;

abstract class ColumnVector implements AutoCloseable {
  // only required methods that have no implementation
  // the others follow
  public abstract void close();
  public abstract boolean hasNull();
  public abstract int numNulls();
  public abstract boolean isNullAt(int rowId);
  public abstract boolean getBoolean(int rowId);
  // other type-specific getters
  protected abstract ColumnVector getChild(int ordinal);
}

package org.apache.spark.sql.vectorized;

abstract class ColumnVector implements AutoCloseable {

// only required methods that have no implementation

// the others follow

public abstract void close();

public abstract boolean hasNull();

public abstract int numNulls();

public abstract boolean isNullAt(int rowId);

public abstract boolean getBoolean(int rowId);

// other type-specific getters

protected abstract ColumnVector getChild(int ordinal);

}

ColumnVector has a data type that you can access using dataType method.



DataType dataType()

DataType dataType()

Note	`ColumnVector` is an `Evolving` contract that is evolving towards becoming a stable API, but is not a stable API yet and can change from one feature release to another release. In other words, using the contract is as treading on thin ice.

Table 1. (Subset of) ColumnVector Contract
Method	Description
`getChild`	Used when…FIXME

Table 2. ColumnVectors
ColumnVector	Description
`ArrowColumnVector`
OffHeapColumnVector
OnHeapColumnVector
`OrcColumnVector`
WritableColumnVector

ColumnVector

ColumnVector

相关推荐

欢迎关注：spark技术分享

热门标签

近期文章

分类目录

关注公众号：spark技术分享

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏

QQ咨询

回顶部