protected <RESULT extends RelatedContent> RESULT createEntity(Map<String, Object> source, Class<? extends RESULT> entityType) {
        try {
            final RESULT result = entityType.newInstance();
            result.setContent(DfTypeUtil.toString(source.get("content")));
            result.setCreatedBy(DfTypeUtil.toString(source.get("createdBy")));
            result.setCreatedTime(DfTypeUtil.toLong(source.get("createdTime")));

    protected final Map<String, PropertyGateway> _epgMap = newHashMap();
    {
        setupEpg(_epgMap, et -> ((RelatedContent) et).getContent(), (et, vl) -> ((RelatedContent) et).setContent(DfTypeUtil.toString(vl)),
                "content");
        setupEpg(_epgMap, et -> ((RelatedContent) et).getCreatedBy(),
                (et, vl) -> ((RelatedContent) et).setCreatedBy(DfTypeUtil.toString(vl)), "createdBy");

                logger.error("Failed to access {}, code: {}.", url, response.getStatusLine().getStatusCode());
                return null;
            }

            data.setContent(EntityUtils.toString(response.getEntity(), Charsets.UTF_8));
            final Header[] headers = response.getAllHeaders();
            for (final Header header : headers) {

        this.hashesExternal = true;
    }

    /**
     * Get the CIFS context associated with this authentication.
     *
     * @return the CIFS context
     */
    protected CIFSContext getContext() {
        return this.context;
    }

    @Override
    public NtlmPasswordAuthentication clone() {
        final NtlmPasswordAuthentication cloned = new NtlmPasswordAuthentication();

    }

    private void setupParentForUrlCreation() throws CIFSException {
        // Only set up parent mocks when they're actually needed for URL creation
        when(parent.getContext()).thenReturn(this.ctx);
        when(parent.getLocator()).thenReturn(parentLocator);
        // Make the parent appear as a workgroup to use the simpler URL code-path
        when(parentLocator.isWorkgroup()).thenReturn(true);

    private RelatedContent createRelatedContent(String term, String content, String virtualHost) {
        RelatedContent entity = new RelatedContent();
        entity.setTerm(term);
        entity.setContent(content);
        entity.setVirtualHost(virtualHost);
        return entity;
    }

    // Mock classes

    static class MockRelatedContentBhv extends RelatedContentBhv {

        if (activeWatchers.containsKey(directoryPath)) {
            return; // Already watching
        }

        try {
            SmbFile directory = new SmbFile(directoryPath, leaseManager.getContext());
            ChangeNotificationHandle handle = new ChangeNotificationHandle(directoryPath, leaseKey, directory);

            activeWatchers.put(directoryPath, handle);

    public ErrorCategory getErrorCategory() {
        return errorCode.getCategory();
    }

    public RetryPolicy getRetryPolicy() {
        return retryPolicy;
    }

    public Map<String, Object> getContext() {
        return Collections.unmodifiableMap(context);
    }

    public long getOperationStartTime() {
        return operationStartTime;
    }

    public String getOperationName() {

                                           TF_Status* status) {
  Node* node = &output.oper->node;

  mutex_lock l(graph->mu);
  tensorflow::shape_inference::InferenceContext* ic =
      graph->refiner.GetContext(node);
  if (ic == nullptr) {
    status->status =
        InvalidArgument("Node ", node->name(), " was not found in the graph");
    return;
  }

  auto shape_and_type_vec =

        }
    }

    /**
     * Get the CIFS context
     *
     * @return CIFS context
     */
    public CIFSContext getContext() {
        return context;
    }

    /**
     * Check if directory notifications are enabled in configuration
     *
     * @param config configuration
     * @return true if notifications are enabled