This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
public class MyWritableComparable implements WritableComparable { | |
// Some data | |
private int counter; | |
private long timestamp; | |
public void write(DataOutput out) throws IOException { | |
out.writeInt(counter); | |
out.writeLong(timestamp); | |
} | |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package org.apache.hadoop.io; | |
public interface WritableComparable<T> extends Writable, Comparable<T> {} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
public interface EventFilter<TEvent> { | |
public enum Decision { | |
Handle, | |
Reject, | |
Retry | |
} | |
Decision filter(TEvent event); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
public interface EnvelopeFilter { | |
public enum Decision { | |
Handle, | |
Reject, | |
Retry | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
public interface Mapper<InKey, InValue, OutKey, OutValue> { | |
void map(InKey key, InValue value, OutputCollector<OutKey, OutValue> output, Reporter reporter) throws IOException; | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Scheme sourceScheme = new TextLine( new Fields( "line" ) ); | |
Tap source = new Hfs( sourceScheme, inputPath ); | |
Scheme sinkScheme = new TextLine( new Fields( "word", "count" ) ); | |
Tap sink = new Hfs( sinkScheme, outputPath, SinkMode.REPLACE ); | |
Pipe assembly = new Pipe( "wordcount" ); | |
String regex = "(?<!\\pL)(?=\\pL)[^ ]*(?<=\\pL)(?!\\pL)"; | |
Function function = new RegexGenerator( new Fields( "word" ), regex ); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<workflow-app name='example' xmlns="uri:oozie:workflow:0.1"> | |
<start to='firstjob' /> | |
<action name="firstjob"> | |
<map-reduce> | |
<job-tracker>${jobtracker}</job-tracker> | |
<name-node>${namenode}</name-node> | |
<configuration> | |
<property><name>mapred.mapper.class</name><value>org.apache.hadoop.example.IdMapper</value></property> | |
<property><name>mapred.reducer.class</name><value>org.apache.hadoop.example.IdReducer</value></property> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<workflow-app name='example' xmlns="uri:oozie:workflow:0.1"> | |
<start to='firstjob' /> | |
<action name="firstjob"> | |
<map-reduce> | |
<job-tracker>${jobtracker}</job-tracker> | |
<name-node>${namenode}</name-node> | |
<configuration> | |
<property><name>mapred.mapper.class</name><value>org.apache.hadoop.example.IdMapper</value></property> | |
<property><name>mapred.reducer.class</name><value>org.apache.hadoop.example.IdReducer</value></property> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Private Sub btnSubmit_Click() | |
Dim found As Boolean | |
found = False | |
Dim i As Integer | |
' Start at the second cell | |
i = 2 | |
' While Combo box value does not match the target cell's value or as long as the cell has a value | |
Do |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
{ | |
"jvm": { | |
"vm": { | |
"name": "Java HotSpot(TM) 64-Bit Server VM", | |
"version": "1.7.0_51-b13" | |
}, | |
"memory": { | |
"totalInit": 51436096, | |
"totalUsed": 76374576, | |
"totalMax": 556007424, |
NewerOlder