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

Writables.strings介绍

暂无

代码示例

代码示例来源：origin: cloudera/crunch

public PType<String> strings() {
 return Writables.strings();
}

代码示例来源：origin: org.apache.crunch/crunch-core

public PType<String> strings() {
 return Writables.strings();
}

代码示例来源：origin: org.apache.crunch/crunch

public PType<String> strings() {
 return Writables.strings();
}

代码示例来源：origin: org.apache.crunch/crunch-core

/**
 * Creates a {@code Source<String>} instance for the text file(s) at the given {@code Path}.
 * 
 * @param path The {@code Path} to the data
 * @return A new {@code Source<String>} instance
 */
public static Source<String> textFile(Path path) {
 return textFile(path, Writables.strings());
}

代码示例来源：origin: org.apache.crunch/crunch-core

/**
 * Creates a {@code SourceTarget<String>} instance for the text file(s) at the given {@code Path}.
 * 
 * @param path The {@code Path} to the data
 * @return A new {@code SourceTarget<String>} instance
 */
public static SourceTarget<String> textFile(Path path) {
 return textFile(path, Writables.strings());
}

代码示例来源：origin: org.apache.crunch/crunch-core

/**
 * Creates a {@code Source<String>} instance for the text file(s) at the given {@code Path}s.
 *
 * @param paths A list of {@code Path}s to the data
 * @return A new {@code Source<String>} instance
 */
public static Source<String> textFile(List<Path> paths) {
 return textFile(paths, Writables.strings());
}

代码示例来源：origin: org.apache.crunch/crunch

/**
 * Creates a {@code Source<String>} instance for the text file(s) at the given {@code Path}.
 * 
 * @param path The {@code Path} to the data
 * @return A new {@code Source<String>} instance
 */
public static Source<String> textFile(Path path) {
 return textFile(path, Writables.strings());
}

代码示例来源：origin: org.apache.crunch/crunch

/**
 * Creates a {@code SourceTarget<String>} instance for the text file(s) at the given {@code Path}.
 * 
 * @param path The {@code Path} to the data
 * @return A new {@code SourceTarget<String>} instance
 */
public static SourceTarget<String> textFile(Path path) {
 return textFile(path, Writables.strings());
}

代码示例来源：origin: cloudera/crunch

public static TextFileSourceTarget<String> textFile(Path path) {
 return textFile(path, Writables.strings());
}

代码示例来源：origin: cloudera/crunch

public static Source<String> textFile(Path path) {
 return textFile(path, Writables.strings());
}

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

/**
 * Extract information from hbase
 *
 * @param words the source from hbase
 * @return a {@code PTable} composed of the type of the input as key
 *         and its def as value
 */
public PTable<String, String> extractText(PTable<ImmutableBytesWritable, Result> words) {
 return words.parallelDo("Extract text", new DoFn<Pair<ImmutableBytesWritable, Result>, Pair<String, String>>() {
  @Override
  public void process(Pair<ImmutableBytesWritable, Result> row, Emitter<Pair<String, String>> emitter) {
   byte[] type = row.second().getValue(COLUMN_FAMILY_SOURCE, COLUMN_QUALIFIER_SOURCE_PLAY);
   byte[] def = row.second().getValue(COLUMN_FAMILY_SOURCE, COLUMN_QUALIFIER_SOURCE_QUOTE);
   if (type != null && def != null) {
    emitter.emit(new Pair<String, String>(Bytes.toString(type), Bytes.toString(def)));
   }
  }
 }, Writables.tableOf(Writables.strings(), Writables.strings()));
}

代码示例来源：origin: org.apache.crunch/crunch-core

super(path, Writables.strings(), getCSVBundle(bufferSize, inputFileEncoding, openQuoteChar, closeQuoteChar,
  escapeChar, maximumRecordSize));
setPrivateVariables(bufferSize, inputFileEncoding, openQuoteChar, closeQuoteChar, escapeChar, maximumRecordSize);

代码示例来源：origin: org.apache.crunch/crunch-core

super(paths, Writables.strings(), getCSVBundle(bufferSize, inputFileEncoding, openQuoteChar, closeQuoteChar,
  escapeChar, maximumRecordSize));
setPrivateVariables(bufferSize, inputFileEncoding, openQuoteChar, closeQuoteChar, escapeChar, maximumRecordSize);

代码示例来源：origin: org.apache.crunch/crunch-core

@Override
public <T> void writeTextFile(PCollection<T> pcollection, String pathName) {
 pcollection.parallelDo("asText", new StringifyFn<T>(), Writables.strings())
   .write(To.textFile(pathName));
}

代码示例来源：origin: org.apache.crunch/crunch

@Override
public <T> void writeTextFile(PCollection<T> pcollection, String pathName) {
 pcollection.parallelDo("asText", new StringifyFn<T>(), Writables.strings())
   .write(To.textFile(pathName));
}

代码示例来源：origin: org.apache.crunch/crunch-core

/**
  * Create new XML data loader using the specified encoding.
  * 
  * @param inputPath
  *          Input XML file location
  * @param tagStart
  *          Elements's start tag
  * @param tagEnd
  *          Elements's end tag
  * @param encoding
  *          Input file encoding
  */
 public XmlSource(String inputPath, String tagStart, String tagEnd, String encoding) {
  super(new Path(inputPath), 
    Writables.strings(), 
    FormatBundle.forInput(XmlInputFormat.class)
     .set(XmlInputFormat.START_TAG_KEY, tagStart)
     .set(XmlInputFormat.END_TAG_KEY, tagEnd)
     .set(XmlInputFormat.ENCODING, encoding));
 }
}

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

}, Writables.strings()); // Indicates the serialization format

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

public int run(String[] args) throws Exception {
 if (args.length != 2) {
  System.err.println();
  System.err.println("Two and only two arguments are accepted.");
  System.err.println("Usage: " + this.getClass().getName() + " [generic options] input output");
  System.err.println();
  GenericOptionsParser.printGenericCommandUsage(System.err);
  return 1;
 }
 // Create an object to coordinate pipeline creation and execution.
 Pipeline pipeline = new MRPipeline(TotalBytesByIP.class, getConf());
 // Reference a given text file as a collection of Strings.
 PCollection<String> lines = pipeline.readTextFile(args[0]);
 // Aggregator used for summing up response size
 Aggregator<Long> agg = Aggregators.SUM_LONGS();
 // Table of (ip, sum(response size))
 PTable<String, Long> ipAddrResponseSize = lines
   .parallelDo(extractIPResponseSize, Writables.tableOf(Writables.strings(), Writables.longs())).groupByKey()
   .combineValues(agg);
 pipeline.writeTextFile(ipAddrResponseSize, args[1]);
 // Execute the pipeline as a MapReduce.
 PipelineResult result = pipeline.done();
 return result.succeeded() ? 0 : 1;
}

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

public int run(String[] args) throws Exception {
 if (args.length != 2) {
  System.err.println();
  System.err.println("Two and only two arguments are accepted.");
  System.err.println("Usage: " + this.getClass().getName() + " [generic options] input output");
  System.err.println();
  GenericOptionsParser.printGenericCommandUsage(System.err);
  return 1;
 }
 // Create an object to coordinate pipeline creation and execution.
 Pipeline pipeline = new MRPipeline(AverageBytesByIP.class, getConf());
 // Reference a given text file as a collection of Strings.
 PCollection<String> lines = pipeline.readTextFile(args[0]);
 // Aggregator used for summing up response size and count
 Aggregator<Pair<Long, Long>> agg = pairAggregator(SUM_LONGS(), SUM_LONGS());
 // Table of (ip, sum(response size), count)
 PTable<String, Pair<Long, Long>> remoteAddrResponseSize = lines
   .parallelDo(extractResponseSize,
     Writables.tableOf(Writables.strings(), Writables.pairs(Writables.longs(), Writables.longs()))).groupByKey()
   .combineValues(agg);
 // Calculate average response size by ip address
 PTable<String, Double> avgs = remoteAddrResponseSize.parallelDo(calulateAverage,
   Writables.tableOf(Writables.strings(), Writables.doubles()));
 // write the result to a text file
 pipeline.writeTextFile(avgs, args[1]);
 // Execute the pipeline as a MapReduce.
 PipelineResult result = pipeline.done();
 return result.succeeded() ? 0 : 1;
}

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

emitter.emit(sb.toString());
}, Writables.strings()).write(To.textFile(args[1]));