本文整理了Java中org.datacleaner.api.Distributed.<init>()
方法的一些代码示例,展示了Distributed.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Distributed.<init>()
方法的具体详情如下:
包路径:org.datacleaner.api.Distributed
类名称:Distributed
方法名:<init>
暂无
代码示例来源:origin: datacleaner/DataCleaner
/**
* Defines abstract methods, metrics etc. for analyzer results of the Value
* Distribution analyzer.
*/
@Distributed(reducer = ValueDistributionAnalyzerResultReducer.class)
public abstract class ValueDistributionAnalyzerResult extends AbstractValueCountingAnalyzerResult {
private static final long serialVersionUID = 1L;
@Metric("Total count")
@Override
public abstract int getTotalCount();
@Metric("Null count")
@Override
public abstract int getNullCount();
@Metric("Unique count")
@Override
public abstract Integer getUniqueCount();
@Metric("Distinct count")
@Override
public abstract Integer getDistinctCount();
}
代码示例来源:origin: datacleaner/DataCleaner
@Distributed(reducer = CharacterSetDistributionResultReducer.class)
public class CharacterSetDistributionResult extends CrosstabResult {
代码示例来源:origin: datacleaner/DataCleaner
@Distributed(reducer = WriteDataResultReducer.class)
public interface WriteDataResult extends AnalyzerResult {
代码示例来源:origin: datacleaner/DataCleaner
@Distributed(reducer = CategorizationResultReducer.class)
public class CategorizationResult implements AnalyzerResult {
代码示例来源:origin: datacleaner/DataCleaner
@Distributed(reducer = NumberAnalyzerResultReducer.class)
public class NumberAnalyzerResult extends CrosstabResult {
代码示例来源:origin: datacleaner/DataCleaner
@Distributed(reducer = ValueMatchAnalyzerResultReducer.class)
public class ValueMatchAnalyzerResult extends AbstractValueCountingAnalyzerResult {
代码示例来源:origin: org.eobjects.datacleaner/DataCleaner-mark-rows
@Description("Marked rows")
@Distributed(reducer = MarkRowsAnalyzerResultReducer.class)
public class MarkRowsAnalyzerResult extends AnnotatedRowsResult {
private static final long serialVersionUID = 1L;
public MarkRowsAnalyzerResult(RowAnnotation annotation, RowAnnotationFactory annotationFactory,
InputColumn<?>[] highlightedColumns) {
super(annotation, annotationFactory, highlightedColumns);
}
@Metric(order = 1, value = "Row count")
public int getTotalRowCount() {
return getAnnotatedRowCount();
}
}
代码示例来源:origin: datacleaner/DataCleaner
@Distributed(true)
abstract class AbstractQueryOptimizedRangeFilter<E>
implements QueryOptimizedFilter<RangeFilterCategory>, Comparator<E>, HasLabelAdvice {
代码示例来源:origin: datacleaner/DataCleaner
@Description("Records with unresolved foreign key values")
@Distributed(reducer = ReferentialIntegrityAnalyzerReducer.class)
public class ReferentialIntegrityAnalyzerResult extends AnnotatedRowsResult {
private static final long serialVersionUID = 1L;
public ReferentialIntegrityAnalyzerResult(final RowAnnotation annotation,
final RowAnnotationFactory annotationFactory, final InputColumn<?>[] highlightedColumns) {
super(annotation, annotationFactory, highlightedColumns);
}
}
代码示例来源:origin: datacleaner/DataCleaner
@Distributed(reducer = PatternFinderResultReducer.class)
public class PatternFinderResult implements AnalyzerResult {
代码示例来源:origin: datacleaner/DataCleaner
@Distributed(reducer = StringAnalyzerResultReducer.class)
public class StringAnalyzerResult extends CrosstabResult {
代码示例来源:origin: datacleaner/DataCleaner
@Description("Marked rows")
@Distributed(reducer = MarkRowsAnalyzerResultReducer.class)
public class MarkRowsAnalyzerResult extends AnnotatedRowsResult {
private static final long serialVersionUID = 1L;
public MarkRowsAnalyzerResult(RowAnnotation annotation, RowAnnotationFactory annotationFactory,
InputColumn<?>[] highlightedColumns) {
super(annotation, annotationFactory, highlightedColumns);
}
@Metric(order = 1, value = "Row count")
public int getTotalRowCount() {
return getAnnotatedRowCount();
}
}
代码示例来源:origin: datacleaner/DataCleaner
@Distributed(reducer = CompletenessAnalyzerResultReducer.class)
public class CompletenessAnalyzerResult extends AnnotatedRowsResult implements AnalyzerResult {
代码示例来源:origin: datacleaner/DataCleaner
@Concurrent(true)
@Categorized(DateAndTimeCategory.class)
@Distributed(reducer = WeekdayDistributionResultReducer.class)
public class WeekdayDistributionAnalyzer implements Analyzer<CrosstabResult> {
代码示例来源:origin: datacleaner/DataCleaner
@Concurrent(true)
@Categorized(DateAndTimeCategory.class)
@Distributed(reducer = DatePartDistributionResultReducer.class)
public class YearDistributionAnalyzer implements Analyzer<CrosstabResult> {
代码示例来源:origin: datacleaner/DataCleaner
@Concurrent(true)
@Categorized(DateAndTimeCategory.class)
@Distributed(reducer = MonthDistributionResultReducer.class)
public class MonthDistributionAnalyzer implements Analyzer<CrosstabResult> {
代码示例来源:origin: datacleaner/DataCleaner
+ "location for staging data or simply storing data temporarily for further analysis.")
@Categorized(superCategory = WriteSuperCategory.class)
@Distributed(false)
public class CreateStagingTableAnalyzer extends AbstractOutputWriterAnalyzer implements HasLabelAdvice {
代码示例来源:origin: datacleaner/DataCleaner
@Concurrent(true)
@Categorized(DateAndTimeCategory.class)
@Distributed(reducer = DatePartDistributionResultReducer.class)
public class WeekNumberDistributionAnalyzer implements Analyzer<CrosstabResult> {
代码示例来源:origin: datacleaner/DataCleaner
@Description("Filter rows that contain null values.")
@Categorized(FilterCategory.class)
@Distributed(true)
public class NullCheckFilter implements QueryOptimizedFilter<NullCheckFilter.NullCheckCategory>, HasLabelAdvice {
代码示例来源:origin: datacleaner/DataCleaner
@Named("Max rows")
@Description("Sets a maximum number of rows to process.")
@Categorized(value = FilterCategory.class)
@Distributed(false)
public class MaxRowsFilter implements QueryOptimizedFilter<MaxRowsFilter.Category>, HasLabelAdvice {
内容来源于网络,如有侵权,请联系作者删除!