Retrieve the FlowStatus with the given key
@param key flow status id key containing group name and flow name
@return {@link FlowStatus} with flow status for the latest execution of the flow
352310
@Override
  public FlowStatus get(ComplexResourceKey<FlowStatusId, EmptyRecord> key) {
    String flowGroup = key.getKey().getFlowGroup();
    String flowName = key.getKey().getFlowName();
    long flowExecutionId = key.getKey().getFlowExecutionId();

    LOG.info("Get called with flowGroup " + flowGroup + " flowName " + flowName + " flowExecutionId " + flowExecutionId);

    org.apache.gobblin.service.monitoring.FlowStatus flowStatus =
        _flowStatusGenerator.getFlowStatus(flowName, flowGroup, flowExecutionId);

    // this returns null to raise a 404 error if flowStatus is null
    return convertFlowStatus(flowStatus);
  }
992432
public final Object get(String key) {
		try {
			this.mutex.acquire();

			return this.valueMap.get(key);
		} finally {
			try {
				this.mutex.release();
			} catch (Exception ignore) {
			}
		}
	}
921107
protected Queue<AsyncResourceRequest<V>> getRequestQueueForExistingKey(K key) {
        Queue<AsyncResourceRequest<V>> requestQueue = requestQueueMap.get(key);
        return requestQueue;
    }
477806
public T get(final int key) {

        final int hash  = hashOf(key);
        int index = hash & mask;
        if (containsKey(key, index)) {
            return (T)values[index];
        }

        if (states[index] == FREE) {
            return missingEntries;
        }

        int j = index;
        for (int perturb = perturb(hash); states[index] != FREE; perturb >>= PERTURB_SHIFT) {
            j = probe(perturb, j);
            index = j & mask;
            if (containsKey(key, index)) {
                return (T)values[index];
            }
        }

        return missingEntries;

    }
1024355
public StreamStatus status(String streamKey) throws QiniuException {
        String path = encodeKey(streamKey) + "/live";
        return get(path, StreamStatus.class);
    }
460170
public <T> T getState(final Flow flow, final String stateId, final Class<T> clazz) {
        if (containsFlowState(flow, stateId)) {
            val state = flow.getState(stateId);
            return clazz.cast(state);
        }
        return null;
    }
120665
@Override
    public String get(final String key) {
        return retrieve(new Callable<String>() {
            @Override
            public String call() throws Exception {
                return configuration.getString(key);
            }
        }, null);
    }
464747
public static function getStatusFromKey($key)
    {
        if (array_key_exists($key, self::$statusList)) {
            return self::$statusList[$key];
        }
        return false;
    }
1315167
public Object get(String key)
    {
        if (syncWorker != null)
            return syncWorker.get(key);
        return null;
    }
1282002
protected String getLockProperty(String key) {
        return lockProps != null ? lockProps.getProperty(key) : null;
    }
687524
public URLConnection get( Object key )
    {
        synchronized( this ) // ensure no ConcurrentModificationException can occur.
        {
            Entry entry = m_hardStore.get( key );
            if( entry == null )
            {
                return null;
            }
            return entry.m_connection;
        }
    }
1237366
public FlowStatus getFlowStatus(FlowStatusId flowStatusId)
      throws RemoteInvocationException {
    LOG.debug("getFlowConfig with groupName " + flowStatusId.getFlowGroup() + " flowName " +
        flowStatusId.getFlowName());

    GetRequest<FlowStatus> getRequest = _flowstatusesRequestBuilders.get()
        .id(new ComplexResourceKey<>(flowStatusId, new EmptyRecord())).build();

    Response<FlowStatus> response =
        _restClient.get().sendRequest(getRequest).getResponse();
    return response.getEntity();
  }
448581
public Object get(String key) {
        return PER_THREAD_CONTEXTS.getUnchecked(Thread.currentThread()).get(key);
    }
287333
public ClusterConfigration getConfig(String key)
      throws MemcachedException, InterruptedException, TimeoutException {
    Command cmd = this.commandFactory.createAWSElasticCacheConfigCommand("get", key);
    final Session session = this.sendCommand(cmd);
    this.latchWait(cmd, opTimeout, session);
    cmd.getIoBuffer().free();
    this.checkException(cmd);
    String result = (String) cmd.getResult();
    if (result == null) {
      throw new MemcachedException("Operation fail,may be caused by networking or timeout");
    }
    return AWSUtils.parseConfiguration(result);
  }
425508
@SuppressWarnings("unchecked")
	public static synchronized <T> T getAdditionalState(String key) {
		return (T) additionalState.get(key);
	}
938241
public static Key<?> getProvidedKey(Key<?> key) {
    Type providerType = key.getTypeLiteral().getType();

    // If the Provider has no type parameter (raw Provider)...
    Preconditions.checkArgument(providerType instanceof ParameterizedType,
        "Expected all providers to be parameterized, but %s wasn't", key);

    Type entryType = ((ParameterizedType) providerType).getActualTypeArguments()[0];

    return key.ofType(entryType);
  }
906208
public String get(final String key) {
        return get(Keys.LANGUAGE, key, Locales.getLocale());
    }