本文整理了Java中org.apache.hyracks.api.context.IHyracksJobletContext.getServiceContext()方法的一些代码示例，展示了IHyracksJobletContext.getServiceContext()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。IHyracksJobletContext.getServiceContext()方法的具体详情如下：
包路径：org.apache.hyracks.api.context.IHyracksJobletContext
类名称：IHyracksJobletContext
方法名：getServiceContext

IHyracksJobletContext.getServiceContext介绍

暂无

代码示例

代码示例来源：origin: apache/asterixdb

public TreeIndexStatsOperatorNodePushable(IHyracksTaskContext ctx, int partition,
    IIndexDataflowHelperFactory indexHelperFactory, IStorageManager storageManager)
    throws HyracksDataException {
  this.ctx = ctx;
  this.treeIndexHelper = indexHelperFactory.create(ctx.getJobletContext().getServiceContext(), partition);
  this.storageManager = storageManager;
}

代码示例来源：origin: apache/asterixdb

public LSMIndexCompactOperatorNodePushable(IHyracksTaskContext ctx, int partition,
    IIndexDataflowHelperFactory indexHelperFactory) throws HyracksDataException {
  this.indexHelper = indexHelperFactory.create(ctx.getJobletContext().getServiceContext(), partition);
}

代码示例来源：origin: apache/asterixdb

public TreeIndexDiskOrderScanOperatorNodePushable(IHyracksTaskContext ctx, int partition,
    IIndexDataflowHelperFactory indexHelperFactory, ISearchOperationCallbackFactory searchCallbackFactory)
    throws HyracksDataException {
  this.ctx = ctx;
  this.treeIndexHelper = indexHelperFactory.create(ctx.getJobletContext().getServiceContext(), partition);
  this.searchCallbackFactory = searchCallbackFactory;
}

代码示例来源：origin: apache/asterixdb

public IndexDropOperatorNodePushable(IIndexDataflowHelperFactory indexHelperFactory, Set<DropOption> options,
    IHyracksTaskContext ctx, int partition) throws HyracksDataException {
  this.indexHelper = indexHelperFactory.create(ctx.getJobletContext().getServiceContext(), partition);
  this.options = options;
}

代码示例来源：origin: apache/asterixdb

public ActiveSourceOperatorNodePushable(IHyracksTaskContext ctx, ActiveRuntimeId runtimeId) {
  this.ctx = ctx;
  activeManager = (ActiveManager) ((INcApplicationContext) ctx.getJobletContext().getServiceContext()
      .getApplicationContext()).getActiveManager();
  this.runtimeId = runtimeId;
}

代码示例来源：origin: apache/asterixdb

@Override
public IRecordReader<char[]> createRecordReader(IHyracksTaskContext ctx, int partition)
    throws HyracksDataException {
  return new PingReader(ctx.getJobletContext().getServiceContext().getNodeId());
}

代码示例来源：origin: apache/asterixdb

public IndexInsertUpdateDeleteOperatorNodePushable(IHyracksTaskContext ctx, int partition,
    IIndexDataflowHelperFactory indexHelperFactory, int[] fieldPermutation, RecordDescriptor inputRecDesc,
    IndexOperation op, IModificationOperationCallbackFactory modOpCallbackFactory,
    ITupleFilterFactory tupleFilterFactory) throws HyracksDataException {
  this.ctx = ctx;
  this.indexHelper = indexHelperFactory.create(ctx.getJobletContext().getServiceContext(), partition);
  this.modOpCallbackFactory = modOpCallbackFactory;
  this.tupleFilterFactory = tupleFilterFactory;
  this.inputRecDesc = inputRecDesc;
  this.op = op;
  this.tuple.setFieldPermutation(fieldPermutation);
}

代码示例来源：origin: apache/asterixdb

@Override
  public ITransactionSubsystem getTransactionSubsystem(IHyracksTaskContext ctx) {
    INcApplicationContext appCtx =
        (INcApplicationContext) ctx.getJobletContext().getServiceContext().getApplicationContext();
    return appCtx.getTransactionSubsystem();
  }
}

代码示例来源：origin: apache/asterixdb

@Override
public void jobletStart() {
  try {
    TransactionOptions options =
        new TransactionOptions(ITransactionManager.AtomicityLevel.ENTITY_LEVEL);
    for (TxnId subTxnId : txnIdMap.values()) {
      ((INcApplicationContext) jobletContext.getServiceContext().getApplicationContext())
          .getTransactionSubsystem().getTransactionManager().beginTransaction(subTxnId, options);
    }
  } catch (ACIDException e) {
    throw new Error(e);
  }
}

代码示例来源：origin: apache/asterixdb

public IndexBulkLoadOperatorNodePushable(IIndexDataflowHelperFactory indexDataflowHelperFactory,
    IHyracksTaskContext ctx, int partition, int[] fieldPermutation, float fillFactor, boolean verifyInput,
    long numElementsHint, boolean checkIfEmptyIndex, RecordDescriptor recDesc) throws HyracksDataException {
  this.ctx = ctx;
  this.indexHelper = indexDataflowHelperFactory.create(ctx.getJobletContext().getServiceContext(), partition);
  this.fillFactor = fillFactor;
  this.verifyInput = verifyInput;
  this.numElementsHint = numElementsHint;
  this.checkIfEmptyIndex = checkIfEmptyIndex;
  this.recDesc = recDesc;
  tuple.setFieldPermutation(fieldPermutation);
}

代码示例来源：origin: apache/asterixdb

@Override
public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException {
  return (ExternalScalarFunction) ExternalFunctionProvider.getExternalFunctionEvaluator(finfo, args, ctx,
      appCtx == null
          ? (IApplicationContext) ctx.getJobletContext().getServiceContext().getApplicationContext()
          : appCtx);
}

代码示例来源：origin: apache/asterixdb

@Override
public IRecordReader<char[]> createRecordReader(IHyracksTaskContext ctx, int partition)
    throws HyracksDataException {
  INCServiceContext serviceCtx = ctx.getJobletContext().getServiceContext();
  INcApplicationContext appCtx = (INcApplicationContext) serviceCtx.getApplicationContext();
  DatasetLifecycleManager dsLifecycleMgr = (DatasetLifecycleManager) appCtx.getDatasetLifecycleManager();
  DatasetResource dsr = dsLifecycleMgr.getDatasetLifecycle(datasetId);
  return new StorageComponentsReader(ctx.getJobletContext().getServiceContext().getNodeId(), dsr);
}

代码示例来源：origin: apache/asterixdb

@Override
  public IIndexBuilder create(IHyracksTaskContext ctx, int partition) throws HyracksDataException {
    FileReference resourceRef = fileSplitProvider.getFileSplits()[partition].getFileReference(ctx.getIoManager());
    return new IndexBuilder(ctx.getJobletContext().getServiceContext(), storageManager,
        storageManager.getResourceIdFactory(ctx.getJobletContext().getServiceContext()), resourceRef,
        localResourceFactory, durable);
  }
}

代码示例来源：origin: apache/asterixdb

private void restoreConfig(IHyracksTaskContext ctx) throws HyracksDataException {
  if (!configured) {
    conf = confFactory.getConf();
    inputSplits = inputSplitsFactory.getSplits();
    nodeName = ctx.getJobletContext().getServiceContext().getNodeId();
    configured = true;
  }
}

代码示例来源：origin: apache/asterixdb

@Override
public void jobletStart() {
  try {
    TransactionOptions options = new TransactionOptions(AtomicityLevel.ENTITY_LEVEL);
    ((INcApplicationContext) jobletContext.getServiceContext().getApplicationContext())
        .getTransactionSubsystem().getTransactionManager().beginTransaction(txnId, options);
  } catch (ACIDException e) {
    throw new Error(e);
  }
}

代码示例来源：origin: apache/asterixdb

public FeedCollectOperatorNodePushable(IHyracksTaskContext ctx, FeedConnectionId feedConnectionId,
    Map<String, String> feedPolicy, int partition) {
  this.ctx = ctx;
  this.partition = partition;
  this.connectionId = feedConnectionId;
  this.policyAccessor = new FeedPolicyAccessor(feedPolicy);
  this.activeManager = (ActiveManager) ((INcApplicationContext) ctx.getJobletContext().getServiceContext()
      .getApplicationContext()).getActiveManager();
}

代码示例来源：origin: apache/asterixdb

@Override
public IRecordReader<char[]> createRecordReader(IHyracksTaskContext ctx, int partition) {
  INCServiceContext serviceCtx = ctx.getJobletContext().getServiceContext();
  INcApplicationContext appCtx = (INcApplicationContext) serviceCtx.getApplicationContext();
  DatasetLifecycleManager dsLifecycleMgr = (DatasetLifecycleManager) appCtx.getDatasetLifecycleManager();
  DatasetResource dsr = dsLifecycleMgr.getDatasetLifecycle(datasetId);
  return new DatasetResourcesReader(dsr);
}

代码示例来源：origin: apache/asterixdb

@Override
  protected void init(int pageSize, int numPages, ITypeTraits[] typeTraits, IBinaryComparatorFactory[] cmpFactories)
      throws HyracksDataException {
    IHyracksTaskContext ctx = TestUtils.create(HYRACKS_FRAME_SIZE);
    TestStorageManagerComponentHolder.init(pageSize, numPages, MAX_OPEN_FILES);
    bufferCache = TestStorageManagerComponentHolder.getBufferCache(ctx.getJobletContext().getServiceContext());
    ITreeIndexMetadataFrameFactory metaFrameFactory = new LIFOMetaDataFrameFactory();
    LinkedMetaDataPageManager freePageManager = new LinkedMetaDataPageManager(bufferCache, metaFrameFactory);
    btree = BTreeUtils.createBTree(bufferCache, typeTraits, cmpFactories, BTreeLeafFrameType.REGULAR_NSM, file,
        freePageManager, false);
  }
}

代码示例来源：origin: apache/asterixdb

private void createSecondaryIndex()
    throws HyracksDataException, RemoteException, ACIDException, AlgebricksException {
  SecondaryIndexInfo secondaryIndexInfo =
      nc.createSecondaryIndex(primaryIndexInfo, secondaryIndex, storageManager, 0);
  IndexDataflowHelperFactory iHelperFactory =
      new IndexDataflowHelperFactory(nc.getStorageManager(), secondaryIndexInfo.getFileSplitProvider());
  secondaryIndexDataflowHelper = iHelperFactory.create(taskCtx.getJobletContext().getServiceContext(), 0);
  secondaryIndexDataflowHelper.open();
  secondaryLsmBtree = (TestLsmBtree) secondaryIndexDataflowHelper.getIndexInstance();
  secondaryIndexDataflowHelper.close();
}

代码示例来源：origin: apache/asterixdb

@Before
public void createIndex() throws Exception {
  PrimaryIndexInfo primaryIndexInfo = StorageTestUtils.createPrimaryIndex(nc, PARTITION);
  IndexDataflowHelperFactory iHelperFactory =
      new IndexDataflowHelperFactory(nc.getStorageManager(), primaryIndexInfo.getFileSplitProvider());
  JobId jobId = nc.newJobId();
  ctx = nc.createTestContext(jobId, PARTITION, false);
  indexDataflowHelper = iHelperFactory.create(ctx.getJobletContext().getServiceContext(), PARTITION);
  indexDataflowHelper.open();
  lsmBtree = (TestLsmBtree) indexDataflowHelper.getIndexInstance();
  indexDataflowHelper.close();
}