Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 /*
  * Druid - a distributed column store.
  * Copyright (C) 2012  Metamarkets Group Inc.
  *
  * This program is free software; you can redistribute it and/or
  * modify it under the terms of the GNU General Public License
  * as published by the Free Software Foundation; either version 2
  * of the License, or (at your option) any later version.
  *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
 */
package io.druid.examples.web;
public class RenamingKeysUpdateStream implements UpdateStream
      InputSupplierUpdateStream updateStream,
      Map<StringStringrenamedDimensions
  )
  {
    this. = renamedDimensions;
    this. = updateStream;
  }
  public Map<StringObjectpollFromQueue(long waitTimeTimeUnit unitthrows InterruptedException
  {
    return renameKeys(.pollFromQueue(waitTimeunit));
  }
  private Map<StringObjectrenameKeys(Map<StringObjectupdate)
  {
    if ( != null) {
      Map<StringObjectrenamedMap = Maps.newHashMap();
      for (String key : .keySet()) {
        if (update.get(key) != null) {
          Object obj = update.get(key);
          renamedMap.put(.get(key), obj);
        }
      }
      return renamedMap;
    } else {
      return update;
    }
  }
  public String getTimeDimension()
  {
    if ( != null && .get(.getTimeDimension()) != null) {
    }
    return .getTimeDimension();
  }
  public void start()
  {
  }
  public void stop(){
    .stop();
  }
New to GrepCode? Check out our FAQ X