@Override
  public void init(Context context) {
    super.init(context);

    Preconditions.checkNotNull(this.context, "Must specify context for local tables.");

    kvStore = this.context.getTaskContext().getStore(tableId);
    Preconditions.checkNotNull(kvStore, String.format(
        "Backing store for table %s was not injected by SamzaContainer", tableId));

    logger.info("Initialized backing store for table " + tableId);
  }
Base class for tables backed by Samza local stores. The backing stores are
injected during initialization of the table. Since the lifecycle
of the underlying stores are already managed by Samza container,
the table provider will not manage the lifecycle of the backing
stores.
samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTableProvider.java