Changeset 975
- Timestamp:
- 08/14/10 12:37:00 (18 months ago)
- Location:
- AnalyzerBeans/trunk/src
- Files:
-
- 47 edited
-
main/java/org/eobjects/analyzer/descriptors/AbstractBeanDescriptor.java (modified) (5 diffs)
-
main/java/org/eobjects/analyzer/descriptors/AnalyzerBeanDescriptor.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/descriptors/AnnotationBasedAnalyzerBeanDescriptor.java (modified) (2 diffs)
-
main/java/org/eobjects/analyzer/descriptors/AnnotationBasedTransformerBeanDescriptor.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/descriptors/BeanDescriptor.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/descriptors/ClasspathScanDescriptorProvider.java (modified) (4 diffs)
-
main/java/org/eobjects/analyzer/descriptors/DescriptorProvider.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/descriptors/LazyDescriptorProvider.java (modified) (2 diffs)
-
main/java/org/eobjects/analyzer/descriptors/SimpleDescriptorProvider.java (modified) (6 diffs)
-
main/java/org/eobjects/analyzer/descriptors/TransformerBeanDescriptor.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/job/AbstractBeanJobBuilder.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/job/AbstractBeanWithInputColumnsBuilder.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/job/AnalysisJobBuilder.java (modified) (11 diffs)
-
main/java/org/eobjects/analyzer/job/AnalyzerJob.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/job/BeanJob.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/job/ExploringAnalyzerJobBuilder.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/job/ImmutableAnalyzerJob.java (modified) (2 diffs)
-
main/java/org/eobjects/analyzer/job/ImmutableTransformerJob.java (modified) (2 diffs)
-
main/java/org/eobjects/analyzer/job/RowProcessingAnalyzerJobBuilder.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/job/TransformerJob.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/job/TransformerJobBuilder.java (modified) (2 diffs)
-
main/java/org/eobjects/analyzer/job/runner/AnalysisRunnerImpl.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/lifecycle/AbstractBeanInstance.java (modified) (3 diffs)
-
main/java/org/eobjects/analyzer/lifecycle/AnalyzerBeanInstance.java (modified) (2 diffs)
-
main/java/org/eobjects/analyzer/lifecycle/AnalyzerLifeCycleCallback.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/lifecycle/AssignConfiguredCallback.java (modified) (2 diffs)
-
main/java/org/eobjects/analyzer/lifecycle/AssignProvidedCallback.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/lifecycle/CloseCallback.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/lifecycle/InitializeCallback.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/lifecycle/LifeCycleCallback.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/lifecycle/ProvidedCollectionCloseCallback.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/lifecycle/ReturnResultsCallback.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/lifecycle/RunExplorerCallback.java (modified) (1 diff)
-
main/java/org/eobjects/analyzer/lifecycle/TransformerBeanInstance.java (modified) (1 diff)
-
test/java/org/eobjects/analyzer/beans/JoinMatcherTest.java (modified) (1 diff)
-
test/java/org/eobjects/analyzer/beans/ReferentialIntegrityValidatorTest.java (modified) (1 diff)
-
test/java/org/eobjects/analyzer/beans/valuedist/ValueDistributionAnalyzerTest.java (modified) (1 diff)
-
test/java/org/eobjects/analyzer/descriptors/AnnotationBasedAnalyzerBeanDescriptorTest.java (modified) (4 diffs)
-
test/java/org/eobjects/analyzer/descriptors/AnnotationBasedTransformerBeanDescriptorTest.java (modified) (2 diffs)
-
test/java/org/eobjects/analyzer/descriptors/ClasspathScanDescriptorProviderTest.java (modified) (3 diffs)
-
test/java/org/eobjects/analyzer/job/AnalysisJobBuilderTest.java (modified) (3 diffs)
-
test/java/org/eobjects/analyzer/job/TransformerJobBuilderTest.java (modified) (3 diffs)
-
test/java/org/eobjects/analyzer/job/runner/RowProcessingPublisherTest.java (modified) (3 diffs)
-
test/java/org/eobjects/analyzer/lifecycle/RunExplorerCallbackTest.java (modified) (1 diff)
-
test/java/org/eobjects/analyzer/test/full/scenarios/NameAndEmailPartEqualityTest.java (modified) (4 diffs)
-
test/java/org/eobjects/analyzer/test/full/scenarios/TokenizerAndValueDistributionTest.java (modified) (2 diffs)
-
test/java/org/eobjects/analyzer/test/full/scenarios/ValueDistributionAndStringAnalysisTest.java (modified) (2 diffs)
Legend:
- Unmodified
- Added
- Removed
-
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/descriptors/AbstractBeanDescriptor.java
r974 r975 24 24 import org.slf4j.LoggerFactory; 25 25 26 public abstract class AbstractBeanDescriptor implements BeanDescriptor{26 public abstract class AbstractBeanDescriptor<B> implements BeanDescriptor<B> { 27 27 28 28 protected final Logger logger = LoggerFactory.getLogger(getClass()); 29 29 30 private final Class< ?> _beanClass;30 private final Class<B> _beanClass; 31 31 protected final Set<InitializeMethodDescriptor> _initializeMethods = new HashSet<InitializeMethodDescriptor>(); 32 32 protected final Set<ConfiguredPropertyDescriptor> _configuredProperties = new HashSet<ConfiguredPropertyDescriptor>(); … … 34 34 protected final Set<CloseMethodDescriptor> _closeMethods = new HashSet<CloseMethodDescriptor>(); 35 35 36 public AbstractBeanDescriptor(Class< ?> beanClass,36 public AbstractBeanDescriptor(Class<B> beanClass, 37 37 boolean requireInputColumns) { 38 38 if (beanClass == null) { … … 144 144 145 145 @Override 146 public Class< ?> getBeanClass() {146 public Class<B> getBeanClass() { 147 147 return _beanClass; 148 148 } … … 197 197 } 198 198 if (obj.getClass() == this.getClass()) { 199 AbstractBeanDescriptor that = (AbstractBeanDescriptor) obj;199 AbstractBeanDescriptor<?> that = (AbstractBeanDescriptor<?>) obj; 200 200 return this._beanClass == that._beanClass; 201 201 } … … 204 204 205 205 @Override 206 public int compareTo(BeanDescriptor o) {206 public int compareTo(BeanDescriptor<?> o) { 207 207 if (o == null) { 208 208 return 1; -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/descriptors/AnalyzerBeanDescriptor.java
r962 r975 1 1 package org.eobjects.analyzer.descriptors; 2 2 3 public interface AnalyzerBeanDescriptor extends BeanDescriptor { 3 import org.eobjects.analyzer.beans.Analyzer; 4 5 public interface AnalyzerBeanDescriptor<B extends Analyzer<?>> extends BeanDescriptor<B> { 4 6 5 7 public boolean isExploringAnalyzer(); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/descriptors/AnnotationBasedAnalyzerBeanDescriptor.java
r967 r975 2 2 3 3 import org.eobjects.analyzer.annotations.AnalyzerBean; 4 import org.eobjects.analyzer.beans.Analyzer; 4 5 import org.eobjects.analyzer.beans.ExploringAnalyzer; 5 6 import org.eobjects.analyzer.beans.RowProcessingAnalyzer; 6 7 import org.eobjects.analyzer.util.ReflectionUtils; 7 8 8 public final class AnnotationBasedAnalyzerBeanDescriptor extends9 AbstractBeanDescriptor implements AnalyzerBeanDescriptor{9 public final class AnnotationBasedAnalyzerBeanDescriptor<A extends Analyzer<?>> 10 extends AbstractBeanDescriptor<A> implements AnalyzerBeanDescriptor<A> { 10 11 11 12 private final String _displayName; … … 13 14 private final boolean _rowProcessingAnalyzer; 14 15 15 public AnnotationBasedAnalyzerBeanDescriptor(Class<?> analyzerClass) 16 public static <A extends Analyzer<?>> AnnotationBasedAnalyzerBeanDescriptor<A> create( 17 Class<A> analyzerClass) { 18 return new AnnotationBasedAnalyzerBeanDescriptor<A>(analyzerClass); 19 } 20 21 private AnnotationBasedAnalyzerBeanDescriptor(Class<A> analyzerClass) 16 22 throws DescriptorException { 17 23 super(analyzerClass, ReflectionUtils.is(analyzerClass, -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/descriptors/AnnotationBasedTransformerBeanDescriptor.java
r967 r975 9 9 import org.eobjects.analyzer.util.ReflectionUtils; 10 10 11 public final class AnnotationBasedTransformerBeanDescriptor extends 12 AbstractBeanDescriptor implements TransformerBeanDescriptor { 11 public final class AnnotationBasedTransformerBeanDescriptor<T extends Transformer<?>> 12 extends AbstractBeanDescriptor<T> implements 13 TransformerBeanDescriptor<T> { 13 14 14 15 private final String _displayName; 15 16 16 public AnnotationBasedTransformerBeanDescriptor(Class<?> transformerClass) 17 public static <T extends Transformer<?>> AnnotationBasedTransformerBeanDescriptor<T> create( 18 Class<T> transformerClass) { 19 return new AnnotationBasedTransformerBeanDescriptor<T>(transformerClass); 20 } 21 22 private AnnotationBasedTransformerBeanDescriptor(Class<T> transformerClass) 17 23 throws DescriptorException { 18 24 super(transformerClass, true); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/descriptors/BeanDescriptor.java
r971 r975 6 6 import org.eobjects.analyzer.data.DataTypeFamily; 7 7 8 public interface BeanDescriptor extends Comparable<BeanDescriptor> { 8 /** 9 * 10 * @author Kasper SÞrensen 11 * 12 * @param <B> 13 * the Bean type 14 */ 15 public interface BeanDescriptor<B> extends Comparable<BeanDescriptor<?>> { 9 16 10 17 public String getDisplayName(); 11 18 12 19 public Set<Annotation> getAnnotations(); 13 20 14 21 public <A extends Annotation> A getAnnotation(Class<A> annotationClass); 15 22 16 public Class< ?> getBeanClass();17 23 public Class<B> getBeanClass(); 24 18 25 public Set<ConfiguredPropertyDescriptor> getConfiguredProperties(); 19 26 20 27 public ConfiguredPropertyDescriptor getConfiguredProperty(String name); 21 28 22 29 public ConfiguredPropertyDescriptor getConfiguredPropertyForInput(); 23 30 24 31 public Set<ProvidedPropertyDescriptor> getProvidedProperties(); 25 32 26 33 public Set<InitializeMethodDescriptor> getInitializeMethods(); 27 34 28 35 public Set<CloseMethodDescriptor> getCloseMethods(); 29 36 30 37 public DataTypeFamily getInputDataTypeFamily(); 31 38 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/descriptors/ClasspathScanDescriptorProvider.java
r971 r975 25 25 private static final Logger logger = LoggerFactory 26 26 .getLogger(ClasspathScanDescriptorProvider.class); 27 private Map<Class<? extends Analyzer<?>>, AnalyzerBeanDescriptor > _analyzerBeanDescriptors = new HashMap<Class<? extends Analyzer<?>>, AnalyzerBeanDescriptor>();28 private Map<Class<? extends Transformer<?>>, TransformerBeanDescriptor > _transformerBeanDescriptors = new HashMap<Class<? extends Transformer<?>>, TransformerBeanDescriptor>();27 private Map<Class<? extends Analyzer<?>>, AnalyzerBeanDescriptor<?>> _analyzerBeanDescriptors = new HashMap<Class<? extends Analyzer<?>>, AnalyzerBeanDescriptor<?>>(); 28 private Map<Class<? extends Transformer<?>>, TransformerBeanDescriptor<?>> _transformerBeanDescriptors = new HashMap<Class<? extends Transformer<?>>, TransformerBeanDescriptor<?>>(); 29 29 private Map<Class<? extends Renderer<?, ?>>, RendererBeanDescriptor> _rendererBeanDescriptors = new HashMap<Class<? extends Renderer<?, ?>>, RendererBeanDescriptor>(); 30 30 … … 76 76 Class<? extends Analyzer<?>> analyzerClass = (Class<? extends Analyzer<?>>) visitor 77 77 .getBeanClass(); 78 AnalyzerBeanDescriptor descriptor = _analyzerBeanDescriptors78 AnalyzerBeanDescriptor<?> descriptor = _analyzerBeanDescriptors 79 79 .get(analyzerClass); 80 80 if (descriptor == null) { 81 descriptor = new AnnotationBasedAnalyzerBeanDescriptor(81 descriptor = AnnotationBasedAnalyzerBeanDescriptor.create( 82 82 analyzerClass); 83 83 _analyzerBeanDescriptors.put(analyzerClass, descriptor); … … 88 88 Class<? extends Transformer<?>> transformerClass = (Class<? extends Transformer<?>>) visitor 89 89 .getBeanClass(); 90 TransformerBeanDescriptor descriptor = _transformerBeanDescriptors90 TransformerBeanDescriptor<?> descriptor = _transformerBeanDescriptors 91 91 .get(transformerClass); 92 92 if (descriptor == null) { 93 descriptor = new AnnotationBasedTransformerBeanDescriptor(93 descriptor = AnnotationBasedTransformerBeanDescriptor.create( 94 94 transformerClass); 95 95 _transformerBeanDescriptors.put(transformerClass, … … 132 132 133 133 @Override 134 public Collection<AnalyzerBeanDescriptor > getAnalyzerBeanDescriptors() {134 public Collection<AnalyzerBeanDescriptor<?>> getAnalyzerBeanDescriptors() { 135 135 return Collections.unmodifiableCollection(_analyzerBeanDescriptors 136 136 .values()); 137 137 } 138 138 139 @SuppressWarnings("unchecked") 139 140 @Override 140 public AnalyzerBeanDescriptor getAnalyzerBeanDescriptorForClass( 141 Class<? extends Analyzer<?>> analyzerBeanClass) { 142 return _analyzerBeanDescriptors.get(analyzerBeanClass); 141 public <A extends Analyzer<?>> AnalyzerBeanDescriptor<A> getAnalyzerBeanDescriptorForClass( 142 Class<A> analyzerBeanClass) { 143 return (AnalyzerBeanDescriptor<A>) _analyzerBeanDescriptors 144 .get(analyzerBeanClass); 143 145 } 144 146 145 147 @Override 146 public Collection<TransformerBeanDescriptor > getTransformerBeanDescriptors() {148 public Collection<TransformerBeanDescriptor<?>> getTransformerBeanDescriptors() { 147 149 return Collections.unmodifiableCollection(_transformerBeanDescriptors 148 150 .values()); 149 151 } 150 152 153 @SuppressWarnings("unchecked") 151 154 @Override 152 public TransformerBeanDescriptor getTransformerBeanDescriptorForClass( 153 Class<? extends Transformer<?>> transformerBeanClass) { 154 return _transformerBeanDescriptors.get(transformerBeanClass); 155 public <T extends Transformer<?>> TransformerBeanDescriptor<T> getTransformerBeanDescriptorForClass( 156 Class<T> transformerBeanClass) { 157 return (TransformerBeanDescriptor<T>) _transformerBeanDescriptors 158 .get(transformerBeanClass); 155 159 } 156 160 -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/descriptors/DescriptorProvider.java
r971 r975 14 14 public interface DescriptorProvider { 15 15 16 public Collection<AnalyzerBeanDescriptor > getAnalyzerBeanDescriptors();16 public Collection<AnalyzerBeanDescriptor<?>> getAnalyzerBeanDescriptors(); 17 17 18 public AnalyzerBeanDescriptorgetAnalyzerBeanDescriptorForClass(19 Class< ? extends Analyzer<?>> analyzerBeanClass);18 public <A extends Analyzer<?>> AnalyzerBeanDescriptor<A> getAnalyzerBeanDescriptorForClass( 19 Class<A> analyzerBeanClass); 20 20 21 public Collection<TransformerBeanDescriptor > getTransformerBeanDescriptors();21 public Collection<TransformerBeanDescriptor<?>> getTransformerBeanDescriptors(); 22 22 23 public TransformerBeanDescriptorgetTransformerBeanDescriptorForClass(24 Class< ? extends Transformer<?>> transformerBeanClass);23 public <T extends Transformer<?>> TransformerBeanDescriptor<T> getTransformerBeanDescriptorForClass( 24 Class<T> transformerBeanClass); 25 25 26 26 public Collection<RendererBeanDescriptor> getRendererBeanDescriptors(); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/descriptors/LazyDescriptorProvider.java
r971 r975 12 12 public class LazyDescriptorProvider implements DescriptorProvider { 13 13 14 private Map<Class<? extends Analyzer<?>>, AnalyzerBeanDescriptor > _analyzerBeanDescriptors = new HashMap<Class<? extends Analyzer<?>>, AnalyzerBeanDescriptor>();15 private Map<Class<? extends Transformer<?>>, TransformerBeanDescriptor > _transformerBeanDescriptors = new HashMap<Class<? extends Transformer<?>>, TransformerBeanDescriptor>();14 private Map<Class<? extends Analyzer<?>>, AnalyzerBeanDescriptor<?>> _analyzerBeanDescriptors = new HashMap<Class<? extends Analyzer<?>>, AnalyzerBeanDescriptor<?>>(); 15 private Map<Class<? extends Transformer<?>>, TransformerBeanDescriptor<?>> _transformerBeanDescriptors = new HashMap<Class<? extends Transformer<?>>, TransformerBeanDescriptor<?>>(); 16 16 private Map<Class<? extends Renderer<?, ?>>, RendererBeanDescriptor> _rendererBeanDescriptors = new HashMap<Class<? extends Renderer<?, ?>>, RendererBeanDescriptor>(); 17 17 18 @SuppressWarnings("unchecked") 18 19 @Override 19 public AnalyzerBeanDescriptorgetAnalyzerBeanDescriptorForClass(20 Class< ? extends Analyzer<?>> analyzerBeanClass) {21 AnalyzerBeanDescriptor descriptor = _analyzerBeanDescriptors20 public <A extends Analyzer<?>> AnalyzerBeanDescriptor<A> getAnalyzerBeanDescriptorForClass( 21 Class<A> analyzerBeanClass) { 22 AnalyzerBeanDescriptor<?> descriptor = _analyzerBeanDescriptors 22 23 .get(analyzerBeanClass); 23 24 if (descriptor == null) { 24 descriptor = new AnnotationBasedAnalyzerBeanDescriptor(25 descriptor = AnnotationBasedAnalyzerBeanDescriptor.create( 25 26 analyzerBeanClass); 26 27 _analyzerBeanDescriptors.put(analyzerBeanClass, descriptor); 27 28 } 28 return descriptor;29 return (AnalyzerBeanDescriptor<A>) descriptor; 29 30 } 30 31 31 32 @Override 32 public Collection<AnalyzerBeanDescriptor > getAnalyzerBeanDescriptors() {33 public Collection<AnalyzerBeanDescriptor<?>> getAnalyzerBeanDescriptors() { 33 34 return Collections.unmodifiableCollection(_analyzerBeanDescriptors 34 35 .values()); … … 36 37 37 38 @Override 38 public Collection<TransformerBeanDescriptor > getTransformerBeanDescriptors() {39 public Collection<TransformerBeanDescriptor<?>> getTransformerBeanDescriptors() { 39 40 return Collections.unmodifiableCollection(_transformerBeanDescriptors 40 41 .values()); 41 42 } 42 43 44 @SuppressWarnings("unchecked") 43 45 @Override 44 public TransformerBeanDescriptorgetTransformerBeanDescriptorForClass(45 Class< ? extends Transformer<?>> transformerBeanClass) {46 TransformerBeanDescriptor descriptor = _transformerBeanDescriptors46 public <T extends Transformer<?>> TransformerBeanDescriptor<T> getTransformerBeanDescriptorForClass( 47 Class<T> transformerBeanClass) { 48 TransformerBeanDescriptor<?> descriptor = _transformerBeanDescriptors 47 49 .get(transformerBeanClass); 48 50 if (descriptor == null) { 49 descriptor = new AnnotationBasedTransformerBeanDescriptor(51 descriptor = AnnotationBasedTransformerBeanDescriptor.create( 50 52 transformerBeanClass); 51 53 _transformerBeanDescriptors.put(transformerBeanClass, descriptor); 52 54 } 53 return descriptor;55 return (TransformerBeanDescriptor<T>) descriptor; 54 56 } 55 57 -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/descriptors/SimpleDescriptorProvider.java
r971 r975 42 42 public class SimpleDescriptorProvider implements DescriptorProvider { 43 43 44 private List<AnalyzerBeanDescriptor > _analyzerBeanDescriptors = new ArrayList<AnalyzerBeanDescriptor>();45 private List<TransformerBeanDescriptor > _transformerBeanDescriptors = new ArrayList<TransformerBeanDescriptor>();44 private List<AnalyzerBeanDescriptor<?>> _analyzerBeanDescriptors = new ArrayList<AnalyzerBeanDescriptor<?>>(); 45 private List<TransformerBeanDescriptor<?>> _transformerBeanDescriptors = new ArrayList<TransformerBeanDescriptor<?>>(); 46 46 private List<RendererBeanDescriptor> _rendererBeanDescriptors = new ArrayList<RendererBeanDescriptor>(); 47 47 … … 50 50 51 51 public void addAnalyzerBeanDescriptor( 52 AnalyzerBeanDescriptor analyzerBeanDescriptor) {52 AnalyzerBeanDescriptor<?> analyzerBeanDescriptor) { 53 53 _analyzerBeanDescriptors.add(analyzerBeanDescriptor); 54 54 } 55 55 56 56 public void addTransformerBeanDescriptor( 57 TransformerBeanDescriptor transformerBeanDescriptor) {57 TransformerBeanDescriptor<?> transformerBeanDescriptor) { 58 58 _transformerBeanDescriptors.add(transformerBeanDescriptor); 59 59 } … … 65 65 66 66 @Override 67 public List<AnalyzerBeanDescriptor > getAnalyzerBeanDescriptors() {67 public List<AnalyzerBeanDescriptor<?>> getAnalyzerBeanDescriptors() { 68 68 return _analyzerBeanDescriptors; 69 69 } 70 70 71 71 public void setAnalyzerBeanDescriptors( 72 List<AnalyzerBeanDescriptor > descriptors) {72 List<AnalyzerBeanDescriptor<?>> descriptors) { 73 73 _analyzerBeanDescriptors = descriptors; 74 74 } 75 75 76 @SuppressWarnings("unchecked") 76 77 @Override 77 public AnalyzerBeanDescriptorgetAnalyzerBeanDescriptorForClass(78 Class< ? extends Analyzer<?>> analyzerBeanClass) {79 for (AnalyzerBeanDescriptor descriptor : _analyzerBeanDescriptors) {78 public <A extends Analyzer<?>> AnalyzerBeanDescriptor<A> getAnalyzerBeanDescriptorForClass( 79 Class<A> analyzerBeanClass) { 80 for (AnalyzerBeanDescriptor<?> descriptor : _analyzerBeanDescriptors) { 80 81 if (descriptor.getBeanClass() == analyzerBeanClass) { 81 return descriptor; 82 return (AnalyzerBeanDescriptor<A>) descriptor; 83 } 84 } 85 return null; 86 } 87 88 @SuppressWarnings("unchecked") 89 @Override 90 public <T extends Transformer<?>> TransformerBeanDescriptor<T> getTransformerBeanDescriptorForClass( 91 Class<T> transformerBeanClass) { 92 for (TransformerBeanDescriptor<?> descriptor : _transformerBeanDescriptors) { 93 if (descriptor.getBeanClass() == transformerBeanClass) { 94 return (TransformerBeanDescriptor<T>) descriptor; 82 95 } 83 96 } … … 86 99 87 100 @Override 88 public TransformerBeanDescriptor getTransformerBeanDescriptorForClass( 89 Class<? extends Transformer<?>> transformerBeanClass) { 90 for (TransformerBeanDescriptor descriptor : _transformerBeanDescriptors) { 91 if (descriptor.getBeanClass() == transformerBeanClass) { 92 return descriptor; 93 } 94 } 95 return null; 96 } 97 98 @Override 99 public List<TransformerBeanDescriptor> getTransformerBeanDescriptors() { 101 public List<TransformerBeanDescriptor<?>> getTransformerBeanDescriptors() { 100 102 return _transformerBeanDescriptors; 101 103 } 102 104 103 105 public void setTransformerBeanDescriptors( 104 List<TransformerBeanDescriptor > transformerBeanDescriptors) {106 List<TransformerBeanDescriptor<?>> transformerBeanDescriptors) { 105 107 _transformerBeanDescriptors = transformerBeanDescriptors; 106 108 } … … 133 135 Class<? extends Analyzer<?>> c = (Class<? extends Analyzer<?>>) Class 134 136 .forName(className); 135 AnalyzerBeanDescriptor descriptor = getAnalyzerBeanDescriptorForClass(c);137 AnalyzerBeanDescriptor<?> descriptor = getAnalyzerBeanDescriptorForClass(c); 136 138 if (descriptor == null) { 137 addAnalyzerBeanDescriptor( new AnnotationBasedAnalyzerBeanDescriptor(138 c));139 addAnalyzerBeanDescriptor(AnnotationBasedAnalyzerBeanDescriptor 140 .create(c)); 139 141 } 140 142 } … … 147 149 Class<? extends Transformer<?>> c = (Class<? extends Transformer<?>>) Class 148 150 .forName(className); 149 TransformerBeanDescriptor descriptor = getTransformerBeanDescriptorForClass(c);151 TransformerBeanDescriptor<?> descriptor = getTransformerBeanDescriptorForClass(c); 150 152 if (descriptor == null) { 151 addTransformerBeanDescriptor( new AnnotationBasedTransformerBeanDescriptor(152 c));153 addTransformerBeanDescriptor(AnnotationBasedTransformerBeanDescriptor 154 .create(c)); 153 155 } 154 156 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/descriptors/TransformerBeanDescriptor.java
r962 r975 1 1 package org.eobjects.analyzer.descriptors; 2 2 3 import org.eobjects.analyzer.beans.Transformer; 3 4 import org.eobjects.analyzer.data.DataTypeFamily; 4 5 5 public interface TransformerBeanDescriptor extends BeanDescriptor{6 public interface TransformerBeanDescriptor<B extends Transformer<?>> extends BeanDescriptor<B> { 6 7 7 8 public DataTypeFamily getOutputDataTypeFamily(); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/AbstractBeanJobBuilder.java
r962 r975 11 11 12 12 @SuppressWarnings("unchecked") 13 class AbstractBeanJobBuilder<D extends BeanDescriptor , B> {13 class AbstractBeanJobBuilder<D extends BeanDescriptor<E>, E, B> { 14 14 15 15 private Map<ConfiguredPropertyDescriptor, Object> _properties = new HashMap<ConfiguredPropertyDescriptor, Object>(); 16 16 private D _descriptor; 17 17 18 public AbstractBeanJobBuilder(D descriptor, Class< B> builderClass) {18 public AbstractBeanJobBuilder(D descriptor, Class<?> builderClass) { 19 19 _descriptor = descriptor; 20 20 if (!ReflectionUtils.is(getClass(), builderClass)) { -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/AbstractBeanWithInputColumnsBuilder.java
r962 r975 14 14 15 15 @SuppressWarnings("unchecked") 16 class AbstractBeanWithInputColumnsBuilder<D extends BeanDescriptor , B> extends17 AbstractBeanJobBuilder<D, B> {16 class AbstractBeanWithInputColumnsBuilder<D extends BeanDescriptor<E>, E, B> 17 extends AbstractBeanJobBuilder<D, E, B> { 18 18 19 19 private List<InputColumn<?>> _inputColumns = new ArrayList<InputColumn<?>>(); 20 20 21 21 public AbstractBeanWithInputColumnsBuilder(D descriptor, 22 Class< B> builderClass) {22 Class<?> builderClass) { 23 23 super(descriptor, builderClass); 24 24 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/AnalysisJobBuilder.java
r957 r975 25 25 private DataContextProvider _dataContextProvider; 26 26 private List<MetaModelInputColumn> _sourceColumns = new ArrayList<MetaModelInputColumn>(); 27 private List<TransformerJobBuilder > _transformerJobBuilders = new ArrayList<TransformerJobBuilder>();28 private List<RowProcessingAnalyzerJobBuilder > _analyzerJobBuilders = new ArrayList<RowProcessingAnalyzerJobBuilder>();27 private List<TransformerJobBuilder<?>> _transformerJobBuilders = new ArrayList<TransformerJobBuilder<?>>(); 28 private List<RowProcessingAnalyzerJobBuilder<?>> _analyzerJobBuilders = new ArrayList<RowProcessingAnalyzerJobBuilder<?>>(); 29 29 private IdGenerator transformedColumnIdGenerator = new PrefixedIdGenerator( 30 30 "trans"); … … 110 110 } 111 111 112 public TransformerJobBuilderaddTransformer(113 Class< ? extends Transformer<?>> transformerClass) {114 TransformerBeanDescriptor descriptor = _configuration112 public <T extends Transformer<?>> TransformerJobBuilder<T> addTransformer( 113 Class<T> transformerClass) { 114 TransformerBeanDescriptor<T> descriptor = _configuration 115 115 .getDescriptorProvider().getTransformerBeanDescriptorForClass( 116 116 transformerClass); … … 122 122 } 123 123 124 public List<TransformerJobBuilder > getTransformerJobBuilders() {124 public List<TransformerJobBuilder<?>> getTransformerJobBuilders() { 125 125 return Collections.unmodifiableList(_transformerJobBuilders); 126 126 } 127 127 128 public TransformerJobBuilderaddTransformer(129 TransformerBeanDescriptor descriptor) {130 TransformerJobBuilder transformerJobBuilder = new TransformerJobBuilder(128 public <T extends Transformer<?>> TransformerJobBuilder<T> addTransformer( 129 TransformerBeanDescriptor<T> descriptor) { 130 TransformerJobBuilder<T> transformerJobBuilder = new TransformerJobBuilder<T>( 131 131 descriptor, transformedColumnIdGenerator); 132 132 _transformerJobBuilders.add(transformerJobBuilder); … … 134 134 } 135 135 136 public AnalysisJobBuilder removeTransformer(TransformerJobBuilder tjb) {136 public AnalysisJobBuilder removeTransformer(TransformerJobBuilder<?> tjb) { 137 137 _transformerJobBuilders.remove(tjb); 138 138 return this; 139 139 } 140 140 141 public List<RowProcessingAnalyzerJobBuilder > getAnalyzerJobBuilders() {141 public List<RowProcessingAnalyzerJobBuilder<?>> getAnalyzerJobBuilders() { 142 142 return Collections.unmodifiableList(_analyzerJobBuilders); 143 143 } 144 144 145 public RowProcessingAnalyzerJobBuilderaddAnalyzer(146 Class< ? extends RowProcessingAnalyzer<?>> analyzerClass) {147 AnalyzerBeanDescriptor descriptor = _configuration145 public <A extends RowProcessingAnalyzer<?>> RowProcessingAnalyzerJobBuilder<A> addAnalyzer( 146 Class<A> analyzerClass) { 147 AnalyzerBeanDescriptor<A> descriptor = _configuration 148 148 .getDescriptorProvider().getAnalyzerBeanDescriptorForClass( 149 149 analyzerClass); … … 152 152 + analyzerClass); 153 153 } 154 RowProcessingAnalyzerJobBuilder analyzerJobBuilder = new RowProcessingAnalyzerJobBuilder(154 RowProcessingAnalyzerJobBuilder<A> analyzerJobBuilder = new RowProcessingAnalyzerJobBuilder<A>( 155 155 descriptor); 156 156 _analyzerJobBuilders.add(analyzerJobBuilder); … … 158 158 } 159 159 160 public AnalysisJobBuilder removeAnalyzer(RowProcessingAnalyzerJobBuilder ajb) { 160 public AnalysisJobBuilder removeAnalyzer( 161 RowProcessingAnalyzerJobBuilder<?> ajb) { 161 162 _analyzerJobBuilders.remove(ajb); 162 163 return this; … … 178 179 } 179 180 180 for (TransformerJobBuilder transformerJobBuilder : _transformerJobBuilders) {181 for (TransformerJobBuilder<?> transformerJobBuilder : _transformerJobBuilders) { 181 182 List<MutableInputColumn<?>> outputColumns = transformerJobBuilder 182 183 .getOutputColumns(); … … 205 206 } 206 207 207 for (TransformerJobBuilder tjb : _transformerJobBuilders) {208 for (TransformerJobBuilder<?> tjb : _transformerJobBuilders) { 208 209 if (!tjb.isConfigured()) { 209 210 return false; … … 211 212 } 212 213 213 for (RowProcessingAnalyzerJobBuilder ajb : _analyzerJobBuilders) {214 for (RowProcessingAnalyzerJobBuilder<?> ajb : _analyzerJobBuilders) { 214 215 if (!ajb.isConfigured()) { 215 216 return false; … … 227 228 228 229 Collection<TransformerJob> transformerJobs = new LinkedList<TransformerJob>(); 229 for (TransformerJobBuilder tjb : _transformerJobBuilders) {230 for (TransformerJobBuilder<?> tjb : _transformerJobBuilders) { 230 231 try { 231 232 TransformerJob transformerJob = tjb.toTransformerJob(); … … 239 240 240 241 Collection<AnalyzerJob> analyzerJobs = new LinkedList<AnalyzerJob>(); 241 for (RowProcessingAnalyzerJobBuilder ajb : _analyzerJobBuilders) {242 for (RowProcessingAnalyzerJobBuilder<?> ajb : _analyzerJobBuilders) { 242 243 try { 243 244 AnalyzerJob analyzerJob = ajb.toAnalyzerJob(); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/AnalyzerJob.java
r938 r975 3 3 import org.eobjects.analyzer.descriptors.AnalyzerBeanDescriptor; 4 4 5 public interface AnalyzerJob extends BeanJob<AnalyzerBeanDescriptor > {5 public interface AnalyzerJob extends BeanJob<AnalyzerBeanDescriptor<?>> { 6 6 7 7 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/BeanJob.java
r962 r975 4 4 import org.eobjects.analyzer.descriptors.BeanDescriptor; 5 5 6 public interface BeanJob<E extends BeanDescriptor > {6 public interface BeanJob<E extends BeanDescriptor<?>> { 7 7 8 8 public E getDescriptor(); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/ExploringAnalyzerJobBuilder.java
r946 r975 1 1 package org.eobjects.analyzer.job; 2 2 3 import org.eobjects.analyzer.beans.ExploringAnalyzer; 3 4 import org.eobjects.analyzer.descriptors.AnalyzerBeanDescriptor; 4 5 5 public class ExploringAnalyzerJobBuilder extends 6 AbstractBeanJobBuilder<AnalyzerBeanDescriptor, ExploringAnalyzerJobBuilder> { 6 public class ExploringAnalyzerJobBuilder<A extends ExploringAnalyzer<?>> 7 extends 8 AbstractBeanJobBuilder<AnalyzerBeanDescriptor<A>, A, ExploringAnalyzerJobBuilder<A>> { 7 9 8 public ExploringAnalyzerJobBuilder(AnalyzerBeanDescriptor descriptor) {10 public ExploringAnalyzerJobBuilder(AnalyzerBeanDescriptor<A> descriptor) { 9 11 super(descriptor, ExploringAnalyzerJobBuilder.class); 10 12 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/ImmutableAnalyzerJob.java
r967 r975 6 6 final class ImmutableAnalyzerJob implements AnalyzerJob { 7 7 8 private final AnalyzerBeanDescriptor _descriptor;8 private final AnalyzerBeanDescriptor<?> _descriptor; 9 9 private final BeanConfiguration _beanConfiguration; 10 10 11 public ImmutableAnalyzerJob(AnalyzerBeanDescriptor descriptor,11 public ImmutableAnalyzerJob(AnalyzerBeanDescriptor<?> descriptor, 12 12 BeanConfiguration beanConfiguration) { 13 13 _descriptor = descriptor; … … 16 16 17 17 @Override 18 public AnalyzerBeanDescriptor getDescriptor() {18 public AnalyzerBeanDescriptor<?> getDescriptor() { 19 19 return _descriptor; 20 20 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/ImmutableTransformerJob.java
r967 r975 12 12 final class ImmutableTransformerJob implements TransformerJob { 13 13 14 private final TransformerBeanDescriptor _descriptor;14 private final TransformerBeanDescriptor<?> _descriptor; 15 15 private final BeanConfiguration _beanConfiguration; 16 16 private final List<MutableInputColumn<?>> _output; 17 17 18 public ImmutableTransformerJob(TransformerBeanDescriptor descriptor,18 public ImmutableTransformerJob(TransformerBeanDescriptor<?> descriptor, 19 19 BeanConfiguration beanConfiguration, 20 20 Collection<MutableInputColumn<?>> output) { … … 26 26 27 27 @Override 28 public TransformerBeanDescriptor getDescriptor() {28 public TransformerBeanDescriptor<?> getDescriptor() { 29 29 return _descriptor; 30 30 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/RowProcessingAnalyzerJobBuilder.java
r946 r975 1 1 package org.eobjects.analyzer.job; 2 2 3 import org.eobjects.analyzer.beans.RowProcessingAnalyzer; 3 4 import org.eobjects.analyzer.descriptors.AnalyzerBeanDescriptor; 4 5 5 public class RowProcessingAnalyzerJobBuilder extends 6 AbstractBeanWithInputColumnsBuilder<AnalyzerBeanDescriptor, RowProcessingAnalyzerJobBuilder> { 6 public class RowProcessingAnalyzerJobBuilder<A extends RowProcessingAnalyzer<?>> 7 extends 8 AbstractBeanWithInputColumnsBuilder<AnalyzerBeanDescriptor<A>, A, RowProcessingAnalyzerJobBuilder<A>> { 7 9 8 public RowProcessingAnalyzerJobBuilder(AnalyzerBeanDescriptor descriptor) {10 public RowProcessingAnalyzerJobBuilder(AnalyzerBeanDescriptor<A> descriptor) { 9 11 super(descriptor, RowProcessingAnalyzerJobBuilder.class); 10 12 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/TransformerJob.java
r938 r975 4 4 import org.eobjects.analyzer.descriptors.TransformerBeanDescriptor; 5 5 6 public interface TransformerJob extends BeanJob<TransformerBeanDescriptor > {6 public interface TransformerJob extends BeanJob<TransformerBeanDescriptor<?>> { 7 7 8 8 public MutableInputColumn<?>[] getOutput(); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/TransformerJobBuilder.java
r956 r975 5 5 6 6 import org.eobjects.analyzer.beans.OutputColumns; 7 import org.eobjects.analyzer.beans.Transformer; 7 8 import org.eobjects.analyzer.data.DataTypeFamily; 8 9 import org.eobjects.analyzer.data.MutableInputColumn; … … 17 18 import org.eobjects.analyzer.lifecycle.TransformerBeanInstance; 18 19 19 public class TransformerJobBuilder 20 /** 21 * @author Kasper SÞrensen 22 * 23 * @param <T> 24 * the transformer type being configured 25 */ 26 public class TransformerJobBuilder<T extends Transformer<?>> 20 27 extends 21 AbstractBeanWithInputColumnsBuilder<TransformerBeanDescriptor , TransformerJobBuilder> {28 AbstractBeanWithInputColumnsBuilder<TransformerBeanDescriptor<T>, T, TransformerJobBuilder<T>> { 22 29 23 30 private LinkedList<MutableInputColumn<?>> _outputColumns = new LinkedList<MutableInputColumn<?>>(); 24 31 private IdGenerator _idGenerator; 25 32 26 public TransformerJobBuilder(TransformerBeanDescriptor descriptor,33 public TransformerJobBuilder(TransformerBeanDescriptor<T> descriptor, 27 34 IdGenerator idGenerator) { 28 35 super(descriptor, TransformerJobBuilder.class); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/runner/AnalysisRunnerImpl.java
r949 r975 82 82 List<AnalyzerJob> rowProcessingJobs = new ArrayList<AnalyzerJob>(); 83 83 for (AnalyzerJob analyzerJob : analyzerJobs) { 84 AnalyzerBeanDescriptor descriptor = analyzerJob.getDescriptor();84 AnalyzerBeanDescriptor<?> descriptor = analyzerJob.getDescriptor(); 85 85 if (descriptor.isExploringAnalyzer()) { 86 86 explorerJobs.add(analyzerJob); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/AbstractBeanInstance.java
r968 r975 19 19 private final Logger logger = LoggerFactory.getLogger(getClass()); 20 20 21 private final BeanDescriptor descriptor;21 private final BeanDescriptor<?> descriptor; 22 22 private final E bean; 23 23 private final List<LifeCycleCallback> assignConfiguredCallbacks = new LinkedList<LifeCycleCallback>(); … … 27 27 28 28 @SuppressWarnings("unchecked") 29 public AbstractBeanInstance(BeanDescriptor descriptor) {29 public AbstractBeanInstance(BeanDescriptor<?> descriptor) { 30 30 if (descriptor == null) { 31 31 throw new IllegalArgumentException("Descriptor cannot be null"); … … 45 45 } 46 46 47 public BeanDescriptor getDescriptor() {47 public BeanDescriptor<?> getDescriptor() { 48 48 return descriptor; 49 49 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/AnalyzerBeanInstance.java
r968 r975 23 23 private final List<AnalyzerLifeCycleCallback> returnResultsCallbacks = new LinkedList<AnalyzerLifeCycleCallback>(); 24 24 25 public AnalyzerBeanInstance(AnalyzerBeanDescriptor descriptor) {25 public AnalyzerBeanInstance(AnalyzerBeanDescriptor<?> descriptor) { 26 26 super(descriptor); 27 27 } … … 53 53 List<AnalyzerLifeCycleCallback> callbacks, LifeCycleState state) { 54 54 for (AnalyzerLifeCycleCallback lifeCycleCallback : callbacks) { 55 lifeCycleCallback.onEvent(state, getBean(), (AnalyzerBeanDescriptor ) getDescriptor());55 lifeCycleCallback.onEvent(state, getBean(), (AnalyzerBeanDescriptor<?>) getDescriptor()); 56 56 } 57 57 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/AnalyzerLifeCycleCallback.java
r957 r975 7 7 8 8 public void onEvent(LifeCycleState state, Analyzer<?> analyzerBean, 9 AnalyzerBeanDescriptor descriptor);9 AnalyzerBeanDescriptor<?> descriptor); 10 10 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/AssignConfiguredCallback.java
r974 r975 22 22 @Override 23 23 public void onEvent(LifeCycleState state, Object bean, 24 BeanDescriptor descriptor) {24 BeanDescriptor<?> descriptor) { 25 25 assert state == LifeCycleState.ASSIGN_CONFIGURED; 26 26 … … 48 48 } 49 49 50 protected Object getValue( 51 ConfiguredPropertyDescriptor propertyDescriptor) { 50 protected Object getValue(ConfiguredPropertyDescriptor propertyDescriptor) { 52 51 logger.debug("Getting property from bean configuration"); 53 52 Object value = _beanConfiguration.getProperty(propertyDescriptor); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/AssignProvidedCallback.java
r974 r975 26 26 @Override 27 27 public void onEvent(LifeCycleState state, Object analyzerBean, 28 BeanDescriptor descriptor) {28 BeanDescriptor<?> descriptor) { 29 29 assert state == LifeCycleState.ASSIGN_PROVIDED; 30 30 -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/CloseCallback.java
r962 r975 10 10 @Override 11 11 public void onEvent(LifeCycleState state, Object analyzerBean, 12 BeanDescriptor descriptor) {12 BeanDescriptor<?> descriptor) { 13 13 assert state == LifeCycleState.CLOSE; 14 14 -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/InitializeCallback.java
r962 r975 10 10 @Override 11 11 public void onEvent(LifeCycleState state, Object analyzerBean, 12 BeanDescriptor descriptor) {12 BeanDescriptor<?> descriptor) { 13 13 assert state == LifeCycleState.INITIALIZE; 14 14 -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/LifeCycleCallback.java
r962 r975 6 6 7 7 public void onEvent(LifeCycleState state, Object bean, 8 BeanDescriptor descriptor);8 BeanDescriptor<?> descriptor); 9 9 } -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/ProvidedCollectionCloseCallback.java
r968 r975 18 18 @Override 19 19 public void onEvent(LifeCycleState state, Object analyzerBean, 20 BeanDescriptor descriptor) {20 BeanDescriptor<?> descriptor) { 21 21 assert state == LifeCycleState.CLOSE; 22 22 -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/ReturnResultsCallback.java
r968 r975 17 17 @Override 18 18 public void onEvent(LifeCycleState state, Analyzer<?> analyzerBean, 19 AnalyzerBeanDescriptor descriptor) {19 AnalyzerBeanDescriptor<?> descriptor) { 20 20 assert state == LifeCycleState.RETURN_RESULTS; 21 21 -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/RunExplorerCallback.java
r968 r975 16 16 @Override 17 17 public void onEvent(LifeCycleState state, Analyzer<?> analyzerBean, 18 AnalyzerBeanDescriptor descriptor) {18 AnalyzerBeanDescriptor<?> descriptor) { 19 19 assert state == LifeCycleState.RUN; 20 20 assert descriptor.isExploringAnalyzer(); -
AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/lifecycle/TransformerBeanInstance.java
r957 r975 6 6 public class TransformerBeanInstance extends AbstractBeanInstance<Transformer<?>> { 7 7 8 public TransformerBeanInstance(TransformerBeanDescriptor descriptor) {8 public TransformerBeanInstance(TransformerBeanDescriptor<?> descriptor) { 9 9 super(descriptor); 10 10 } -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/beans/JoinMatcherTest.java
r974 r975 18 18 19 19 public void testDescriptor() throws Exception { 20 AnalyzerBeanDescriptor descriptor = new AnnotationBasedAnalyzerBeanDescriptor(21 JoinMatcher.class);20 AnalyzerBeanDescriptor<JoinMatcher> descriptor = AnnotationBasedAnalyzerBeanDescriptor 21 .create(JoinMatcher.class); 22 22 23 23 List<ConfiguredPropertyDescriptor> configuredProperties = new ArrayList<ConfiguredPropertyDescriptor>( -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/beans/ReferentialIntegrityValidatorTest.java
r974 r975 47 47 48 48 public void testDescriptor() throws Exception { 49 AnalyzerBeanDescriptor descriptor = new AnnotationBasedAnalyzerBeanDescriptor(49 AnalyzerBeanDescriptor<ReferentialIntegrityValidator> descriptor = AnnotationBasedAnalyzerBeanDescriptor.create( 50 50 ReferentialIntegrityValidator.class); 51 51 assertEquals( -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/beans/valuedist/ValueDistributionAnalyzerTest.java
r962 r975 14 14 15 15 public void testDescriptor() throws Exception { 16 AnalyzerBeanDescriptor desc = new AnnotationBasedAnalyzerBeanDescriptor(16 AnalyzerBeanDescriptor<?> desc = AnnotationBasedAnalyzerBeanDescriptor.create( 17 17 ValueDistributionAnalyzer.class); 18 18 assertEquals(true, desc.isRowProcessingAnalyzer()); -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/descriptors/AnnotationBasedAnalyzerBeanDescriptorTest.java
r974 r975 26 26 27 27 public void testExploringType() throws Exception { 28 AnalyzerBeanDescriptor descriptor = new AnnotationBasedAnalyzerBeanDescriptor(29 ExploringAnalyzerMock.class);28 AnalyzerBeanDescriptor<?> descriptor = AnnotationBasedAnalyzerBeanDescriptor 29 .create(ExploringAnalyzerMock.class); 30 30 assertEquals(true, descriptor.isExploringAnalyzer()); 31 31 assertEquals(false, descriptor.isRowProcessingAnalyzer()); … … 37 37 38 38 public void testRowProcessingType() throws Exception { 39 AnalyzerBeanDescriptor descriptor = new AnnotationBasedAnalyzerBeanDescriptor(40 RowProcessingAnalyzerMock.class);39 AnalyzerBeanDescriptor<RowProcessingAnalyzerMock> descriptor = AnnotationBasedAnalyzerBeanDescriptor 40 .create(RowProcessingAnalyzerMock.class); 41 41 assertEquals(false, descriptor.isExploringAnalyzer()); 42 42 assertEquals(true, descriptor.isRowProcessingAnalyzer()); … … 56 56 57 57 public void testGetInputDataTypeFamily() throws Exception { 58 AnalyzerBeanDescriptor descriptor = new AnnotationBasedAnalyzerBeanDescriptor(59 StringAnalyzer.class);58 AnalyzerBeanDescriptor<?> descriptor = AnnotationBasedAnalyzerBeanDescriptor 59 .create(StringAnalyzer.class); 60 60 assertEquals(DataTypeFamily.STRING, descriptor.getInputDataTypeFamily()); 61 61 62 descriptor = new AnnotationBasedAnalyzerBeanDescriptor(63 ValueDistributionAnalyzer.class);62 descriptor = AnnotationBasedAnalyzerBeanDescriptor 63 .create(ValueDistributionAnalyzer.class); 64 64 assertEquals(DataTypeFamily.UNDEFINED, 65 65 descriptor.getInputDataTypeFamily()); … … 68 68 public void testAbstractBeanClass() throws Exception { 69 69 try { 70 new AnnotationBasedAnalyzerBeanDescriptor(InvalidAnalyzer.class);70 AnnotationBasedAnalyzerBeanDescriptor.create(InvalidAnalyzer.class); 71 71 fail("Exception expected"); 72 72 } catch (DescriptorException e) { -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/descriptors/AnnotationBasedTransformerBeanDescriptorTest.java
r962 r975 12 12 13 13 public void testGetDataTypeFamilies() throws Exception { 14 TransformerBeanDescriptor descriptor = new AnnotationBasedTransformerBeanDescriptor(15 TokenizerTransformer.class);14 TransformerBeanDescriptor<?> descriptor = AnnotationBasedTransformerBeanDescriptor 15 .create(TokenizerTransformer.class); 16 16 assertEquals(DataTypeFamily.STRING, descriptor.getInputDataTypeFamily()); 17 17 assertEquals(DataTypeFamily.STRING, 18 18 descriptor.getOutputDataTypeFamily()); 19 19 20 descriptor = new AnnotationBasedTransformerBeanDescriptor(21 ConvertToNumberTransformer.class);20 descriptor = AnnotationBasedTransformerBeanDescriptor 21 .create(ConvertToNumberTransformer.class); 22 22 assertEquals(DataTypeFamily.STRING, descriptor.getInputDataTypeFamily()); 23 23 assertEquals(DataTypeFamily.NUMBER, 24 24 descriptor.getOutputDataTypeFamily()); 25 25 26 descriptor = new AnnotationBasedTransformerBeanDescriptor(27 ConvertToStringTransformer.class);26 descriptor = AnnotationBasedTransformerBeanDescriptor 27 .create(ConvertToStringTransformer.class); 28 28 assertEquals(DataTypeFamily.UNDEFINED, 29 29 descriptor.getInputDataTypeFamily()); … … 31 31 descriptor.getOutputDataTypeFamily()); 32 32 } 33 33 34 34 public void testConcatenator() throws Exception { 35 TransformerBeanDescriptor descriptor = new AnnotationBasedTransformerBeanDescriptor(36 ConcatenatorTransformer.class);35 TransformerBeanDescriptor<?> descriptor = AnnotationBasedTransformerBeanDescriptor 36 .create(ConcatenatorTransformer.class); 37 37 assertEquals(DataTypeFamily.UNDEFINED, 38 38 descriptor.getInputDataTypeFamily()); 39 39 assertEquals(DataTypeFamily.STRING, 40 descriptor.getOutputDataTypeFamily()); 40 descriptor.getOutputDataTypeFamily()); 41 41 } 42 42 } -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/descriptors/ClasspathScanDescriptorProviderTest.java
r971 r975 10 10 public void testScanNonExistingPackage() throws Exception { 11 11 ClasspathScanDescriptorProvider provider = new ClasspathScanDescriptorProvider(); 12 Collection<AnalyzerBeanDescriptor > analyzerDescriptors = provider12 Collection<AnalyzerBeanDescriptor<?>> analyzerDescriptors = provider 13 13 .scanPackage("org.eobjects.analyzer.nonexistingbeans", true) 14 14 .getAnalyzerBeanDescriptors(); … … 21 21 public void testScanPackageRecursive() throws Exception { 22 22 ClasspathScanDescriptorProvider descriptorProvider = new ClasspathScanDescriptorProvider(); 23 Collection<AnalyzerBeanDescriptor > analyzerDescriptors = descriptorProvider23 Collection<AnalyzerBeanDescriptor<?>> analyzerDescriptors = descriptorProvider 24 24 .scanPackage("org.eobjects.analyzer.beans.mock", true) 25 25 .getAnalyzerBeanDescriptors(); … … 30 30 Arrays.toString(array)); 31 31 32 Collection<TransformerBeanDescriptor > transformerBeanDescriptors = descriptorProvider32 Collection<TransformerBeanDescriptor<?>> transformerBeanDescriptors = descriptorProvider 33 33 .getTransformerBeanDescriptors(); 34 34 assertEquals( -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/job/AnalysisJobBuilderTest.java
r958 r975 56 56 57 57 public void testToString() throws Exception { 58 RowProcessingAnalyzerJobBuilder ajb = analysisJobBuilder58 RowProcessingAnalyzerJobBuilder<StringAnalyzer> ajb = analysisJobBuilder 59 59 .addAnalyzer(StringAnalyzer.class); 60 TransformerJobBuilder tjb = analysisJobBuilder60 TransformerJobBuilder<ConvertToStringTransformer> tjb = analysisJobBuilder 61 61 .addTransformer(ConvertToStringTransformer.class); 62 62 … … 81 81 employeeTable.getColumnByName("EMAIL")); 82 82 83 TransformerJobBuilder transformerJobBuilder = analysisJobBuilder83 TransformerJobBuilder<ConvertToStringTransformer> transformerJobBuilder = analysisJobBuilder 84 84 .addTransformer(ConvertToStringTransformer.class); 85 85 … … 97 97 assertFalse(analysisJobBuilder.isConfigured()); 98 98 99 RowProcessingAnalyzerJobBuilder analyzerJobBuilder = analysisJobBuilder99 RowProcessingAnalyzerJobBuilder<StringAnalyzer> analyzerJobBuilder = analysisJobBuilder 100 100 .addAnalyzer(StringAnalyzer.class); 101 101 -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/job/TransformerJobBuilderTest.java
r958 r975 28 28 29 29 public void testSetInvalidPropertyType() throws Exception { 30 TransformerJobBuilder tjb = ajb30 TransformerJobBuilder<TokenizerTransformer> tjb = ajb 31 31 .addTransformer(TokenizerTransformer.class); 32 32 try { … … 41 41 42 42 public void testIsConfigured() throws Exception { 43 TransformerJobBuilder tjb = ajb43 TransformerJobBuilder<TokenizerTransformer> tjb = ajb 44 44 .addTransformer(TokenizerTransformer.class); 45 45 assertFalse(tjb.isConfigured()); … … 66 66 67 67 public void testInvalidInputColumnType() throws Exception { 68 TransformerJobBuilder tjb = ajb68 TransformerJobBuilder<ConvertToNumberTransformer> tjb = ajb 69 69 .addTransformer(ConvertToNumberTransformer.class); 70 70 assertEquals(1, tjb.getOutputColumns().size()); -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/job/runner/RowProcessingPublisherTest.java
r958 r975 43 43 ajb.addSourceColumn(physicalColumn); 44 44 45 TransformerJobBuilder tjb1 = ajb.addTransformer(TransformerMock.class) 46 .addInputColumn(ajb.getSourceColumns().get(0)); 47 TransformerJobBuilder tjb2 = ajb.addTransformer(TransformerMock.class) 48 .addInputColumn(tjb1.getOutputColumns().get(0)); 49 TransformerJobBuilder tjb3 = ajb.addTransformer( 50 ConvertToStringTransformer.class).addInputColumn( 51 tjb2.getOutputColumns().get(0)); 45 TransformerJobBuilder<TransformerMock> tjb1 = ajb.addTransformer( 46 TransformerMock.class).addInputColumn( 47 ajb.getSourceColumns().get(0)); 48 TransformerJobBuilder<TransformerMock> tjb2 = ajb.addTransformer( 49 TransformerMock.class).addInputColumn( 50 tjb1.getOutputColumns().get(0)); 51 TransformerJobBuilder<ConvertToStringTransformer> tjb3 = ajb 52 .addTransformer(ConvertToStringTransformer.class) 53 .addInputColumn(tjb2.getOutputColumns().get(0)); 52 54 53 55 ajb.addAnalyzer(StringAnalyzer.class).addInputColumn( … … 95 97 jobDependencies.add(transformerJobs.get(2)); 96 98 jobDependencies.add(analyzerJobs.get(1)); 97 99 98 100 int jobDependenciesFound = 0; 99 101 boolean analyzerJob1found = false; … … 113 115 } 114 116 } 115 117 116 118 assertTrue(analyzerJob1found); 117 119 assertEquals(4, jobDependenciesFound); -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/lifecycle/RunExplorerCallbackTest.java
r964 r975 26 26 ExploringAnalyzer<?> analyzer = EasyMock 27 27 .createMock(ExploringAnalyzer.class); 28 AnalyzerBeanDescriptor descriptor = EasyMock28 AnalyzerBeanDescriptor<?> descriptor = EasyMock 29 29 .createMock(AnalyzerBeanDescriptor.class); 30 30 -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/test/full/scenarios/NameAndEmailPartEqualityTest.java
r966 r975 77 77 analysisJobBuilder.addSourceColumns(nameColumn, emailColumn); 78 78 79 TransformerJobBuilder nameTransformerJobBuilder = analysisJobBuilder79 TransformerJobBuilder<NameStandardizerTransformer> nameTransformerJobBuilder = analysisJobBuilder 80 80 .addTransformer(NameStandardizerTransformer.class); 81 81 nameTransformerJobBuilder.addInputColumn(analysisJobBuilder … … 94 94 assertEquals("Titulation", nameColumns.get(3).getName()); 95 95 96 TransformerJobBuilder emailTransformerJobBuilder = analysisJobBuilder96 TransformerJobBuilder<EmailStandardizerTransformer> emailTransformerJobBuilder = analysisJobBuilder 97 97 .addTransformer(EmailStandardizerTransformer.class); 98 98 emailTransformerJobBuilder.addInputColumn(analysisJobBuilder … … 110 110 111 111 for (InputColumn<?> inputColumn : nameColumns) { 112 RowProcessingAnalyzerJobBuilder analyzerJobBuilder = analysisJobBuilder112 RowProcessingAnalyzerJobBuilder<ValueDistributionAnalyzer> analyzerJobBuilder = analysisJobBuilder 113 113 .addAnalyzer(ValueDistributionAnalyzer.class); 114 114 analyzerJobBuilder.addInputColumn(inputColumn); … … 122 122 } 123 123 124 RowProcessingAnalyzerJobBuilder equalsAnalyzerJobBuilder = analysisJobBuilder124 RowProcessingAnalyzerJobBuilder<EqualityAnalyzer> equalsAnalyzerJobBuilder = analysisJobBuilder 125 125 .addAnalyzer(EqualityAnalyzer.class); 126 126 equalsAnalyzerJobBuilder.addInputColumns( -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/test/full/scenarios/TokenizerAndValueDistributionTest.java
r949 r975 69 69 analysisJobBuilder.addSourceColumns(jobTitleColumn); 70 70 71 TransformerJobBuilder transformerJobBuilder = analysisJobBuilder71 TransformerJobBuilder<TokenizerTransformer> transformerJobBuilder = analysisJobBuilder 72 72 .addTransformer(TokenizerTransformer.class); 73 73 transformerJobBuilder.addInputColumn(analysisJobBuilder … … 84 84 85 85 for (InputColumn<?> inputColumn : transformerOutput) { 86 RowProcessingAnalyzerJobBuilder valueDistribuitionJobBuilder = analysisJobBuilder86 RowProcessingAnalyzerJobBuilder<ValueDistributionAnalyzer> valueDistribuitionJobBuilder = analysisJobBuilder 87 87 .addAnalyzer(ValueDistributionAnalyzer.class); 88 88 valueDistribuitionJobBuilder.addInputColumn(inputColumn); -
AnalyzerBeans/trunk/src/test/java/org/eobjects/analyzer/test/full/scenarios/ValueDistributionAndStringAnalysisTest.java
r949 r975 72 72 73 73 for (InputColumn<?> inputColumn : analysisJobBuilder.getSourceColumns()) { 74 RowProcessingAnalyzerJobBuilder valueDistribuitionJobBuilder = analysisJobBuilder74 RowProcessingAnalyzerJobBuilder<ValueDistributionAnalyzer> valueDistribuitionJobBuilder = analysisJobBuilder 75 75 .addAnalyzer(ValueDistributionAnalyzer.class); 76 76 valueDistribuitionJobBuilder.addInputColumn(inputColumn); … … 85 85 columns = table.getLiteralColumns(); 86 86 87 RowProcessingAnalyzerJobBuilder stringAnalyzerJob = analysisJobBuilder87 RowProcessingAnalyzerJobBuilder<StringAnalyzer> stringAnalyzerJob = analysisJobBuilder 88 88 .addAnalyzer(StringAnalyzer.class); 89 89 stringAnalyzerJob.addInputColumns(analysisJobBuilder
Note: See TracChangeset
for help on using the changeset viewer.
