本文整理汇总了Java中org.apache.pig.tools.pigstats.PigProgressNotificationListener类的典型用法代码示例。如果您正苦于以下问题：Java PigProgressNotificationListener类的具体用法？Java PigProgressNotificationListener怎么用？Java PigProgressNotificationListener使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
PigProgressNotificationListener类属于org.apache.pig.tools.pigstats包，在下文中一共展示了PigProgressNotificationListener类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: exec
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
private PigStats exec(String query) throws IOException {
LOG.info("Query to run:\n" + query);
List<PigProgressNotificationListener> listeners = ScriptState.get()
.getAllListeners();
ScriptState.start("embedded", scriptContext.getPigContext());
ScriptState.get().setScript(query);
for (PigProgressNotificationListener listener : listeners) {
ScriptState.get().registerListener(listener);
}
PigServer pigServer = new PigServer(scriptContext.getPigContext(), false);
pigServer.setBatchOn();
GruntParser grunt = new GruntParser(new StringReader(query));
grunt.setInteractive(false);
grunt.setParams(pigServer);
try {
grunt.parseStopOnError(true);
} catch (ParseException e) {
throw new IOException("Failed to parse script " + e.getMessage(), e);
}
pigServer.executeBatch();
return PigStats.get();
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:23，代码来源:BoundScript.java
示例2: exec
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
private PigStats exec(String query) throws IOException {
LOG.info("Query to run:\n" + query);
List<PigProgressNotificationListener> listeners = ScriptState.get().getAllListeners();
PigContext pc = scriptContext.getPigContext();
ScriptState scriptState = pc.getExecutionEngine().instantiateScriptState();
ScriptState.start(scriptState);
ScriptState.get().setScript(query);
for (PigProgressNotificationListener listener : listeners) {
ScriptState.get().registerListener(listener);
}
PigServer pigServer = new PigServer(scriptContext.getPigContext(), false);
pigServer.setBatchOn();
GruntParser grunt = new GruntParser(new StringReader(query), pigServer);
grunt.setInteractive(false);
try {
grunt.parseStopOnError(true);
} catch (ParseException e) {
throw new IOException("Failed to parse script " + e.getMessage(), e);
}
pigServer.executeBatch();
return PigStats.get();
}
开发者ID:sigmoidanalytics，项目名称:spork，代码行数:23，代码来源:BoundScript.java
示例3: jobFailedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void jobFailedNotification(String scriptId, JobStats jobStats) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.jobFailedNotification(scriptId, jobStats);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例4: jobFinishedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void jobFinishedNotification(String scriptId, JobStats jobStats) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.jobFinishedNotification(scriptId, jobStats);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例5: jobStartedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void jobStartedNotification(String scriptId, String assignedJobId) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.jobStartedNotification(scriptId, assignedJobId);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例6: jobsSubmittedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void jobsSubmittedNotification(String scriptId, int numJobsSubmitted) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.jobsSubmittedNotification(scriptId, numJobsSubmitted);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例7: launchCompletedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void launchCompletedNotification(String scriptId,
int numJobsSucceeded) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.launchCompletedNotification(scriptId, numJobsSucceeded);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:10，代码来源:SyncProgressNotificationAdaptor.java
示例8: initialPlanNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void initialPlanNotification(String scriptId, MROperPlan plan) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
try {
listener.initialPlanNotification(scriptId, plan);
} catch (NoSuchMethodError e) {
LOG.warn("PigProgressNotificationListener implementation doesn't "
+ "implement initialPlanNotification(..) method: "
+ listener.getClass().getName(), e);
}
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:15，代码来源:SyncProgressNotificationAdaptor.java
示例9: launchStartedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void launchStartedNotification(String scriptId, int numJobsToLaunch) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.launchStartedNotification(scriptId, numJobsToLaunch);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例10: outputCompletedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void outputCompletedNotification(String scriptId,
OutputStats outputStats) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.outputCompletedNotification(scriptId, outputStats);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:10，代码来源:SyncProgressNotificationAdaptor.java
示例11: progressUpdatedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void progressUpdatedNotification(String scriptId, int progress) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.progressUpdatedNotification(scriptId, progress);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例12: makeListener
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
protected static PigProgressNotificationListener makeListener(Properties properties) {
try {
return PigContext.instantiateObjectFromParams(
ConfigurationUtil.toConfiguration(properties),
PROGRESS_NOTIFICATION_LISTENER_KEY,
PROGRESS_NOTIFICATION_LISTENER_ARG_KEY,
PigProgressNotificationListener.class);
} catch (ExecException e) {
throw new RuntimeException(e);
}
}
开发者ID:sigmoidanalytics，项目名称:spork-streaming，代码行数:13，代码来源:Main.java
示例13: jobFailedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void jobFailedNotification(String scriptId, JobStats jobStats) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.jobFailedNotification(scriptId, jobStats);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例14: jobFinishedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void jobFinishedNotification(String scriptId, JobStats jobStats) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.jobFinishedNotification(scriptId, jobStats);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例15: jobStartedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void jobStartedNotification(String scriptId, String assignedJobId) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.jobStartedNotification(scriptId, assignedJobId);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例16: jobsSubmittedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void jobsSubmittedNotification(String scriptId, int numJobsSubmitted) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.jobsSubmittedNotification(scriptId, numJobsSubmitted);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例17: launchCompletedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void launchCompletedNotification(String scriptId,
int numJobsSucceeded) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.launchCompletedNotification(scriptId, numJobsSucceeded);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork，代码行数:10，代码来源:SyncProgressNotificationAdaptor.java
示例18: initialPlanNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void initialPlanNotification(String scriptId, OperatorPlan<?> plan) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
try {
listener.initialPlanNotification(scriptId, plan);
} catch (NoSuchMethodError e) {
LOG.warn("PigProgressNotificationListener implementation doesn't "
+ "implement initialPlanNotification(..) method: "
+ listener.getClass().getName(), e);
}
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork，代码行数:15，代码来源:SyncProgressNotificationAdaptor.java
示例19: launchStartedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void launchStartedNotification(String scriptId, int numJobsToLaunch) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.launchStartedNotification(scriptId, numJobsToLaunch);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork，代码行数:9，代码来源:SyncProgressNotificationAdaptor.java
示例20: outputCompletedNotification
import org.apache.pig.tools.pigstats.PigProgressNotificationListener; //导入依赖的package包/类
@Override
public void outputCompletedNotification(String scriptId,
OutputStats outputStats) {
synchronized (listeners) {
for (PigProgressNotificationListener listener : listeners) {
listener.outputCompletedNotification(scriptId, outputStats);
}
}
}
开发者ID:sigmoidanalytics，项目名称:spork，代码行数:10，代码来源:SyncProgressNotificationAdaptor.java
注：本文中的org.apache.pig.tools.pigstats.PigProgressNotificationListener类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论